[jira] [Updated] (CONNECTORS-1391) The Kafka output connector UI test fails

["Karl Wright (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/CONNECTORS-1391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Karl Wright updated CONNECTORS-1391:
------------------------------------
    Fix Version/s: ManifoldCF 2.7

> The Kafka output connector UI test fails
> ----------------------------------------
>
>                 Key: CONNECTORS-1391
>                 URL: https://issues.apache.org/jira/browse/CONNECTORS-1391
>             Project: ManifoldCF
>          Issue Type: Bug
>         Environment: Windows 10
> java version "1.8.0_73"
>            Reporter: Markus Schuch
>            Assignee: Furkan KAMACI
>            Priority: Minor
>             Fix For: ManifoldCF 2.7
>
>
> Whenn runnint the UI tests with
> {code}
> .../trunk> ant uitest
> {code}
> the kafka output connector UI test fails:
> {code}
> run-UI-HSQLDB:
>     [mkdir] Created dir: D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output
>     [junit] Testsuite: org.apache.manifoldcf.agents.output.kafka.NavigationHSQLDBUI
>     [junit] Configuration file successfully read
>     [junit] [main] INFO org.eclipse.jetty.util.log - Logging initialized @1457ms
>     [junit] [main] INFO org.eclipse.jetty.server.Server - jetty-9.2.3.v20140905
>     [junit] [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.w.WebAppContext@77eca502{/mcf-crawler-ui,file:/C:/Users/Markus/AppData/Local/Temp/jetty-0.0.0.0-8346-mcf-crawler-ui.war-_mcf-crawler-ui-any-8910054509415332620.dir/webapp/,AVAILABLE}{D:\code\manifoldcf_trunk\dist/web/war/mcf-crawler-ui.war}
>     [junit] [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.w.WebAppContext@3246fb96{/mcf-authority-service,file:/C:/Users/Markus/AppData/Local/Temp/jetty-0.0.0.0-8346-mcf-authority-service.war-_mcf-authority-service-any-3957204946994965733.dir/webapp/,AVAILABLE}{D:\code\manifoldcf_trunk\dist/web/war/mcf-authority-service.war}
>     [junit] [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.w.WebAppContext@2e222612{/mcf-api-service,file:/C:/Users/Markus/AppData/Local/Temp/jetty-0.0.0.0-8346-mcf-api-service.war-_mcf-api-service-any-7710121541795189855.dir/webapp/,AVAILABLE}{D:\code\manifoldcf_trunk\dist/web/war/mcf-api-service.war}
>     [junit] [main] INFO org.eclipse.jetty.server.ServerConnector - Started ServerConnector@7857fe2{HTTP/1.1}{0.0.0.0:8346}
>     [junit] [main] INFO org.eclipse.jetty.server.Server - Started @3239ms
>     [junit] [qtp1217467887-204] INFO org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values:
>     [junit]     compression.type = none
>     [junit]     metric.reporters = []
>     [junit]     metadata.max.age.ms = 300000
>     [junit]     metadata.fetch.timeout.ms = 60000
>     [junit]     acks = all
>     [junit]     batch.size = 200
>     [junit]     reconnect.backoff.ms = 10
>     [junit]     bootstrap.servers = [localhost:9092]
>     [junit]     receive.buffer.bytes = 32768
>     [junit]     retry.backoff.ms = 100
>     [junit]     buffer.memory = 33554432
>     [junit]     timeout.ms = 30000
>     [junit]     key.serializer = class org.apache.kafka.common.serialization.StringSerializer
>     [junit]     retries = 3
>     [junit]     max.request.size = 1048576
>     [junit]     block.on.buffer.full = true
>     [junit]     value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
>     [junit]     metrics.sample.window.ms = 30000
>     [junit]     send.buffer.bytes = 131072
>     [junit]     max.in.flight.requests.per.connection = 5
>     [junit]     metrics.num.samples = 2
>     [junit]     linger.ms = 0
>     [junit]     client.id =
>     [junit]
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [qtp1217467887-204] WARN org.eclipse.jetty.servlet.ServletHandler -
>     [junit] org.apache.jasper.JasperException: org.apache.jasper.JasperException: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
>     [junit]     at org.apache.jasper.servlet.JspServletWrapper.handleJspException(JspServletWrapper.java:502)
>     [junit]     at org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:412)
>     [junit]     at org.apache.jasper.servlet.JspServlet.serviceJspFile(JspServlet.java:313)
>     [junit]     at org.apache.jasper.servlet.JspServlet.service(JspServlet.java:260)
>     [junit]     at javax.servlet.http.HttpServlet.service(HttpServlet.java:790)
>     [junit]     at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:769)
>     [junit]     at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:585)
>     [junit]     at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143)
>     [junit]     at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:577)
>     [junit]     at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:223)
>     [junit]     at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1125)
>     [junit]     at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:515)
>     [junit]     at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:185)
>     [junit] Starting test
>     [junit]     at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1059)
>     [junit]     at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
>     [junit]     at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:215)
>     [junit]     at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:97)
>     [junit]     at org.eclipse.jetty.server.Server.handle(Server.java:497)
>     [junit]     at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:311)
>     [junit]     at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:248)
>     [junit]     at org.eclipse.jetty.io.AbstractConnection$2.run(AbstractConnection.java:540)
>     [junit]     at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:610)
>     [junit]     at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:539)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] Caused by: org.apache.jasper.JasperException: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
>     [junit]     at org.apache.jasper.servlet.JspServletWrapper.handleJspException(JspServletWrapper.java:502)
>     [junit]     at org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:430)
>     [junit]     at org.apache.jasper.servlet.JspServlet.serviceJspFile(JspServlet.java:313)
>     [junit]     at org.apache.jasper.servlet.JspServlet.service(JspServlet.java:260)
>     [junit]     at javax.servlet.http.HttpServlet.service(HttpServlet.java:790)
>     [junit]     at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:769)
>     [junit]     at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:585)
>     [junit]     at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143)
>     [junit]     at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:595)
>     [junit]     at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:223)
>     [junit]     at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1125)
>     [junit]     at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:515)
>     [junit]     at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:185)
>     [junit]     at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1059)
>     [junit]     at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
>     [junit]     at org.eclipse.jetty.server.Dispatcher.forward(Dispatcher.java:191)
>     [junit]     at org.eclipse.jetty.server.Dispatcher.forward(Dispatcher.java:72)
>     [junit]     at org.apache.jasper.runtime.PageContextImpl.doForward(PageContextImpl.java:709)
>     [junit]     at org.apache.jasper.runtime.PageContextImpl.forward(PageContextImpl.java:680)
>     [junit]     at org.apache.jsp.execute_jsp._jspService(execute_jsp.java:1135)
>     [junit]     at org.apache.jasper.runtime.HttpJspBase.service(HttpJspBase.java:70)
>     [junit]     at javax.servlet.http.HttpServlet.service(HttpServlet.java:790)
>     [junit]     at org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:388)
>     [junit]     ... 22 more
>     [junit] Caused by: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
>     [junit] Getting url 'http://localhost:8346/mcf-crawler-ui/index.jsp'...
>     [junit] Redirecting from url 'http://localhost:8346/mcf-crawler-ui/index.jsp' to url 'http://localhost:8346/mcf-crawler-ui/login.jsp'...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/index.jsp
>     [junit] Form of type POST detected
>     [junit] Posting url 'http://localhost:8346/mcf-crawler-ui/setupAdminProfile.jsp' with parameters 'password=admin&userID=admin'...
>     [junit] Redirecting from url 'http://localhost:8346/mcf-crawler-ui/setupAdminProfile.jsp' to url 'http://localhost:8346/mcf-crawler-ui/index.jsp'...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/setupAdminProfile.jsp
>     [junit] Getting url 'http://localhost:8346/mcf-crawler-ui/listoutputs.jsp'...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/listoutputs.jsp
>     [junit] Form of type POST detected
>     [junit] Getting url 'http://localhost:8346/mcf-crawler-ui/editoutput.jsp'...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/editoutput.jsp
>     [junit] Form of type MULTIPART detected
>     [junit] Multipart posting url 'http://localhost:8346/mcf-crawler-ui/execute.jsp' with parameters 'description=&connname=MyOutputConnection&isnewconnection=true&classname=&tabname=Type&maxconnections=10&type=output&op=Continue' and 0 files...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/execute.jsp
>     [junit] Form of type MULTIPART detected
>     [junit] Multipart posting url 'http://localhost:8346/mcf-crawler-ui/execute.jsp' with parameters 'description=&connname=MyOutputConnection&isnewconnection=true&classname=org.apache.manifoldcf.agents.output.kafka.KafkaOutputConnector&tabname=Type&maxconnections=10&type=output&op=Continue' and 0 files...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/execute.jsp
>     [junit] Form of type MULTIPART detected
>     [junit] Multipart posting url 'http://localhost:8346/mcf-crawler-ui/execute.jsp' with parameters 'ip=localhost&topic=topic&description=&connname=MyOutputConnection&isnewconnection=true&classname=org.apache.manifoldcf.agents.output.kafka.KafkaOutputConnector&tabname=Throttling&maxconnections=10&type=output&port=9092&op=Continue' and 0 files...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/execute.jsp
>     [junit] Form of type MULTIPART detected
>     [junit] Multipart posting url 'http://localhost:8346/mcf-crawler-ui/execute.jsp' with parameters 'ip=localhost&topic=topic&description=&connname=MyOutputConnection&isnewconnection=true&classname=org.apache.manifoldcf.agents.output.kafka.KafkaOutputConnector&tabname=Name&maxconnections=10&type=output&port=9092&op=Continue' and 0 files...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/execute.jsp
>     [junit] Form of type MULTIPART detected
>     [junit] Multipart posting url 'http://localhost:8346/mcf-crawler-ui/execute.jsp' with parameters 'ip=localhost&topic=topic&description=&connname=MyOutputConnection&isnewconnection=true&classname=org.apache.manifoldcf.agents.output.kafka.KafkaOutputConnector&tabname=Parameters&maxconnections=10&type=output&port=9092&op=Continue' and 0 files...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/execute.jsp
>     [junit] Form of type MULTIPART detected
>     [junit] Multipart posting url 'http://localhost:8346/mcf-crawler-ui/execute.jsp' with parameters 'ip=localhost&topic=topic&description=&connname=MyOutputConnection&isnewconnection=true&classname=org.apache.manifoldcf.agents.output.kafka.KafkaOutputConnector&tabname=Name&maxconnections=10&type=output&port=9092&op=Continue' and 0 files...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/execute.jsp
>     [junit] Form of type MULTIPART detected
>     [junit] Multipart posting url 'http://localhost:8346/mcf-crawler-ui/execute.jsp' with parameters 'ip=localhost&topic=topic&description=&connname=MyOutputConnection&isnewconnection=true&classname=org.apache.manifoldcf.agents.output.kafka.KafkaOutputConnector&tabname=Name&maxconnections=10&type=output&port=9092&op=Save' and 0 files...
>     [junit] Traceback (most recent call last):
>     [junit]   File "test.py", line 84, in <module>
>     [junit]     var59.click()
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 125, in click
>     [junit]     self.get_form( ).execute_javascript_expression( self.onclick )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 720, in execute_javascript_expression
>     [junit]     return self.window_instance.execute_javascript_expression( javascript )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 1013, in execute_javascript_expression
>     [junit]     return tokenstream.evaluate_expr( self.jscontext, "HTML" )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1133, in evaluate_expr
>     [junit]     rval = self.evaluate_expr0( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1209, in evaluate_expr0
>     [junit]     rval = self.evaluate_expr1( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1232, in evaluate_expr1
>     [junit]     rval = self.evaluate_expr2( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1255, in evaluate_expr2
>     [junit]     rval = self.evaluate_expr3( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1276, in evaluate_expr3
>     [junit]     rval = self.evaluate_expr4( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1297, in evaluate_expr4
>     [junit]     rval = self.evaluate_expr5( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1319, in evaluate_expr5
>     [junit]     rval = self.evaluate_expr6( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1364, in evaluate_expr6
>     [junit]     rval = self.evaluate_expr7( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1424, in evaluate_expr7
>     [junit]     rval = self.evaluate_expr8( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1460, in evaluate_expr8
>     [junit]     rval = self.evaluate_expr9( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1599, in evaluate_expr9
>     [junit]     rval = self.evaluate_expr10( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1709, in evaluate_expr10
>     [junit]     reference_object = reference_object.call( arguments, context )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 582, in call
>     [junit]     return self.dereference().call(argset,context)
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 210, in call
>     [junit]     response = ts.evaluate_statement( context, "method %s" % self.name )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 789, in evaluate_statement
>     [junit]     result = self.evaluate_statement( newscope, place )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 853, in evaluate_statement
>     [junit]     rval = self.evaluate_statement( context, place )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 789, in evaluate_statement
>     [junit]     result = self.evaluate_statement( newscope, place )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1031, in evaluate_statement
>     [junit]     if self.evaluate_expr( context, place ) == None:
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1133, in evaluate_expr
>     [junit]     rval = self.evaluate_expr0( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1209, in evaluate_expr0
>     [junit]     rval = self.evaluate_expr1( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1232, in evaluate_expr1
>     [junit]     rval = self.evaluate_expr2( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1255, in evaluate_expr2
>     [junit]     rval = self.evaluate_expr3( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1276, in evaluate_expr3
>     [junit]     rval = self.evaluate_expr4( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1297, in evaluate_expr4
>     [junit]     rval = self.evaluate_expr5( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1319, in evaluate_expr5
>     [junit]     rval = self.evaluate_expr6( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1364, in evaluate_expr6
>     [junit]     rval = self.evaluate_expr7( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1424, in evaluate_expr7
>     [junit]     rval = self.evaluate_expr8( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1460, in evaluate_expr8
>     [junit]     rval = self.evaluate_expr9( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1599, in evaluate_expr9
>     [junit]     rval = self.evaluate_expr10( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1709, in evaluate_expr10
>     [junit]     reference_object = reference_object.call( arguments, context )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 582, in call
>     [junit]     return self.dereference().call(argset,context)
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 1448, in call
>     [junit]     self.form_instance.submit( )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 754, in submit
>     [junit]     self.window_instance.execute_action( self.method, variables, files, self.action_url )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 1021, in execute_action
>     [junit]     return self.browser_instance.execute_action( self.window_name, method, parameters, files, self.resolve( url ) )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 1160, in execute_action
>     [junit]     window_data = self.fetch_data_with_multipart_post( parameters, files, url )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 1235, in fetch_data_with_multipart_post
>     [junit]     return self.talk_to_server(url, method="POST", content_type=content_type, body=body)
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 1324, in talk_to_server
>     [junit]     raise Exception("Received an error response %d from url: '%s'" % (status,url) )
>     [junit] Exception: Received an error response 500 from url: 'http://localhost:8346/mcf-crawler-ui/execute.jsp'
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [main] INFO org.eclipse.jetty.server.ServerConnector - Stopped ServerConnector@7857fe2{HTTP/1.1}{0.0.0.0:8346}
>     [junit] [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Stopped o.e.j.w.WebAppContext@2e222612{/mcf-api-service,file:/C:/Users/Markus/AppData/Local/Temp/jetty-0.0.0.0-8346-mcf-api-service.war-_mcf-api-service-any-7710121541795189855.dir/webapp/,UNAVAILABLE}{D:\code\manifoldcf_trunk\dist/web/war/mcf-api-service.war}
>     [junit] [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Stopped o.e.j.w.WebAppContext@3246fb96{/mcf-authority-service,file:/C:/Users/Markus/AppData/Local/Temp/jetty-0.0.0.0-8346-mcf-authority-service.war-_mcf-authority-service-any-3957204946994965733.dir/webapp/,UNAVAILABLE}{D:\code\manifoldcf_trunk\dist/web/war/mcf-authority-service.war}
>     [junit] [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Stopped o.e.j.w.WebAppContext@77eca502{/mcf-crawler-ui,file:/C:/Users/Markus/AppData/Local/Temp/jetty-0.0.0.0-8346-mcf-crawler-ui.war-_mcf-crawler-ui-any-8910054509415332620.dir/webapp/,UNAVAILABLE}{D:\code\manifoldcf_trunk\dist/web/war/mcf-crawler-ui.war}
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 76,404 sec
>     [junit]
>     [junit] ------------- Standard Output ---------------
>     [junit] Starting test
>     [junit] ------------- ---------------- ---------------
>     [junit] ------------- Standard Error -----------------
>     [junit] Configuration file successfully read
>     [junit] [main] INFO org.eclipse.jetty.util.log - Logging initialized @1457ms
>     [junit] [main] INFO org.eclipse.jetty.server.Server - jetty-9.2.3.v20140905
>     [junit] [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.w.WebAppContext@77eca502{/mcf-crawler-ui,file:/C:/Users/Markus/AppData/Local/Temp/jetty-0.0.0.0-8346-mcf-crawler-ui.war-_mcf-crawler-ui-any-8910054509415332620.dir/webapp/,AVAILABLE}{D:\code\manifoldcf_trunk\dist/web/war/mcf-crawler-ui.war}
>     [junit] [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.w.WebAppContext@3246fb96{/mcf-authority-service,file:/C:/Users/Markus/AppData/Local/Temp/jetty-0.0.0.0-8346-mcf-authority-service.war-_mcf-authority-service-any-3957204946994965733.dir/webapp/,AVAILABLE}{D:\code\manifoldcf_trunk\dist/web/war/mcf-authority-service.war}
>     [junit] [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.w.WebAppContext@2e222612{/mcf-api-service,file:/C:/Users/Markus/AppData/Local/Temp/jetty-0.0.0.0-8346-mcf-api-service.war-_mcf-api-service-any-7710121541795189855.dir/webapp/,AVAILABLE}{D:\code\manifoldcf_trunk\dist/web/war/mcf-api-service.war}
>     [junit] [main] INFO org.eclipse.jetty.server.ServerConnector - Started ServerConnector@7857fe2{HTTP/1.1}{0.0.0.0:8346}
>     [junit] [main] INFO org.eclipse.jetty.server.Server - Started @3239ms
>     [junit] [qtp1217467887-204] INFO org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values:
>     [junit]     compression.type = none
>     [junit]     metric.reporters = []
>     [junit]     metadata.max.age.ms = 300000
>     [junit]     metadata.fetch.timeout.ms = 60000
>     [junit]     acks = all
>     [junit]     batch.size = 200
>     [junit]     reconnect.backoff.ms = 10
>     [junit]     bootstrap.servers = [localhost:9092]
>     [junit]     receive.buffer.bytes = 32768
>     [junit]     retry.backoff.ms = 100
>     [junit]     buffer.memory = 33554432
>     [junit]     timeout.ms = 30000
>     [junit]     key.serializer = class org.apache.kafka.common.serialization.StringSerializer
>     [junit]     retries = 3
>     [junit]     max.request.size = 1048576
>     [junit]     block.on.buffer.full = true
>     [junit]     value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer
>     [junit]     metrics.sample.window.ms = 30000
>     [junit]     send.buffer.bytes = 131072
>     [junit]     max.in.flight.requests.per.connection = 5
>     [junit]     metrics.num.samples = 2
>     [junit]     linger.ms = 0
>     [junit]     client.id =
>     [junit]
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [qtp1217467887-204] WARN org.eclipse.jetty.servlet.ServletHandler -
>     [junit] org.apache.jasper.JasperException: org.apache.jasper.JasperException: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
>     [junit]     at org.apache.jasper.servlet.JspServletWrapper.handleJspException(JspServletWrapper.java:502)
>     [junit]     at org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:412)
>     [junit]     at org.apache.jasper.servlet.JspServlet.serviceJspFile(JspServlet.java:313)
>     [junit]     at org.apache.jasper.servlet.JspServlet.service(JspServlet.java:260)
>     [junit]     at javax.servlet.http.HttpServlet.service(HttpServlet.java:790)
>     [junit]     at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:769)
>     [junit]     at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:585)
>     [junit]     at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143)
>     [junit]     at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:577)
>     [junit]     at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:223)
>     [junit]     at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1125)
>     [junit]     at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:515)
>     [junit]     at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:185)
>     [junit]     at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1059)
>     [junit]     at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
>     [junit]     at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:215)
>     [junit]     at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:97)
>     [junit]     at org.eclipse.jetty.server.Server.handle(Server.java:497)
>     [junit]     at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:311)
>     [junit]     at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:248)
>     [junit]     at org.eclipse.jetty.io.AbstractConnection$2.run(AbstractConnection.java:540)
>     [junit]     at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:610)
>     [junit]     at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:539)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] Caused by: org.apache.jasper.JasperException: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
>     [junit]     at org.apache.jasper.servlet.JspServletWrapper.handleJspException(JspServletWrapper.java:502)
>     [junit]     at org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:430)
>     [junit]     at org.apache.jasper.servlet.JspServlet.serviceJspFile(JspServlet.java:313)
>     [junit]     at org.apache.jasper.servlet.JspServlet.service(JspServlet.java:260)
>     [junit]     at javax.servlet.http.HttpServlet.service(HttpServlet.java:790)
>     [junit]     at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:769)
>     [junit]     at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:585)
>     [junit]     at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143)
>     [junit]     at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:595)
>     [junit]     at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:223)
>     [junit]     at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1125)
>     [junit]     at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:515)
>     [junit]     at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:185)
>     [junit]     at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1059)
>     [junit]     at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
>     [junit]     at org.eclipse.jetty.server.Dispatcher.forward(Dispatcher.java:191)
>     [junit]     at org.eclipse.jetty.server.Dispatcher.forward(Dispatcher.java:72)
>     [junit]     at org.apache.jasper.runtime.PageContextImpl.doForward(PageContextImpl.java:709)
>     [junit]     at org.apache.jasper.runtime.PageContextImpl.forward(PageContextImpl.java:680)
>     [junit]     at org.apache.jsp.execute_jsp._jspService(execute_jsp.java:1135)
>     [junit]     at org.apache.jasper.runtime.HttpJspBase.service(HttpJspBase.java:70)
>     [junit]     at javax.servlet.http.HttpServlet.service(HttpServlet.java:790)
>     [junit]     at org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:388)
>     [junit]     ... 22 more
>     [junit] Caused by: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
>     [junit] Getting url 'http://localhost:8346/mcf-crawler-ui/index.jsp'...
>     [junit] Redirecting from url 'http://localhost:8346/mcf-crawler-ui/index.jsp' to url 'http://localhost:8346/mcf-crawler-ui/login.jsp'...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/index.jsp
>     [junit] Form of type POST detected
>     [junit] Posting url 'http://localhost:8346/mcf-crawler-ui/setupAdminProfile.jsp' with parameters 'password=admin&userID=admin'...
>     [junit] Redirecting from url 'http://localhost:8346/mcf-crawler-ui/setupAdminProfile.jsp' to url 'http://localhost:8346/mcf-crawler-ui/index.jsp'...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/setupAdminProfile.jsp
>     [junit] Getting url 'http://localhost:8346/mcf-crawler-ui/listoutputs.jsp'...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/listoutputs.jsp
>     [junit] Form of type POST detected
>     [junit] Getting url 'http://localhost:8346/mcf-crawler-ui/editoutput.jsp'...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/editoutput.jsp
>     [junit] Form of type MULTIPART detected
>     [junit] Multipart posting url 'http://localhost:8346/mcf-crawler-ui/execute.jsp' with parameters 'description=&connname=MyOutputConnection&isnewconnection=true&classname=&tabname=Type&maxconnections=10&type=output&op=Continue' and 0 files...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/execute.jsp
>     [junit] Form of type MULTIPART detected
>     [junit] Multipart posting url 'http://localhost:8346/mcf-crawler-ui/execute.jsp' with parameters 'description=&connname=MyOutputConnection&isnewconnection=true&classname=org.apache.manifoldcf.agents.output.kafka.KafkaOutputConnector&tabname=Type&maxconnections=10&type=output&op=Continue' and 0 files...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/execute.jsp
>     [junit] Form of type MULTIPART detected
>     [junit] Multipart posting url 'http://localhost:8346/mcf-crawler-ui/execute.jsp' with parameters 'ip=localhost&topic=topic&description=&connname=MyOutputConnection&isnewconnection=true&classname=org.apache.manifoldcf.agents.output.kafka.KafkaOutputConnector&tabname=Throttling&maxconnections=10&type=output&port=9092&op=Continue' and 0 files...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/execute.jsp
>     [junit] Form of type MULTIPART detected
>     [junit] Multipart posting url 'http://localhost:8346/mcf-crawler-ui/execute.jsp' with parameters 'ip=localhost&topic=topic&description=&connname=MyOutputConnection&isnewconnection=true&classname=org.apache.manifoldcf.agents.output.kafka.KafkaOutputConnector&tabname=Name&maxconnections=10&type=output&port=9092&op=Continue' and 0 files...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/execute.jsp
>     [junit] Form of type MULTIPART detected
>     [junit] Multipart posting url 'http://localhost:8346/mcf-crawler-ui/execute.jsp' with parameters 'ip=localhost&topic=topic&description=&connname=MyOutputConnection&isnewconnection=true&classname=org.apache.manifoldcf.agents.output.kafka.KafkaOutputConnector&tabname=Parameters&maxconnections=10&type=output&port=9092&op=Continue' and 0 files...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/execute.jsp
>     [junit] Form of type MULTIPART detected
>     [junit] Multipart posting url 'http://localhost:8346/mcf-crawler-ui/execute.jsp' with parameters 'ip=localhost&topic=topic&description=&connname=MyOutputConnection&isnewconnection=true&classname=org.apache.manifoldcf.agents.output.kafka.KafkaOutputConnector&tabname=Name&maxconnections=10&type=output&port=9092&op=Continue' and 0 files...
>     [junit] Loading window '' with data from url http://localhost:8346/mcf-crawler-ui/execute.jsp
>     [junit] Form of type MULTIPART detected
>     [junit] Multipart posting url 'http://localhost:8346/mcf-crawler-ui/execute.jsp' with parameters 'ip=localhost&topic=topic&description=&connname=MyOutputConnection&isnewconnection=true&classname=org.apache.manifoldcf.agents.output.kafka.KafkaOutputConnector&tabname=Name&maxconnections=10&type=output&port=9092&op=Save' and 0 files...
>     [junit] Traceback (most recent call last):
>     [junit]   File "test.py", line 84, in <module>
>     [junit]     var59.click()
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 125, in click
>     [junit]     self.get_form( ).execute_javascript_expression( self.onclick )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 720, in execute_javascript_expression
>     [junit]     return self.window_instance.execute_javascript_expression( javascript )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 1013, in execute_javascript_expression
>     [junit]     return tokenstream.evaluate_expr( self.jscontext, "HTML" )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1133, in evaluate_expr
>     [junit]     rval = self.evaluate_expr0( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1209, in evaluate_expr0
>     [junit]     rval = self.evaluate_expr1( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1232, in evaluate_expr1
>     [junit]     rval = self.evaluate_expr2( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1255, in evaluate_expr2
>     [junit]     rval = self.evaluate_expr3( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1276, in evaluate_expr3
>     [junit]     rval = self.evaluate_expr4( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1297, in evaluate_expr4
>     [junit]     rval = self.evaluate_expr5( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1319, in evaluate_expr5
>     [junit]     rval = self.evaluate_expr6( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1364, in evaluate_expr6
>     [junit]     rval = self.evaluate_expr7( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1424, in evaluate_expr7
>     [junit]     rval = self.evaluate_expr8( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1460, in evaluate_expr8
>     [junit]     rval = self.evaluate_expr9( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1599, in evaluate_expr9
>     [junit]     rval = self.evaluate_expr10( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1709, in evaluate_expr10
>     [junit]     reference_object = reference_object.call( arguments, context )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 582, in call
>     [junit]     return self.dereference().call(argset,context)
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 210, in call
>     [junit]     response = ts.evaluate_statement( context, "method %s" % self.name )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 789, in evaluate_statement
>     [junit]     result = self.evaluate_statement( newscope, place )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 853, in evaluate_statement
>     [junit]     rval = self.evaluate_statement( context, place )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 789, in evaluate_statement
>     [junit]     result = self.evaluate_statement( newscope, place )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1031, in evaluate_statement
>     [junit]     if self.evaluate_expr( context, place ) == None:
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1133, in evaluate_expr
>     [junit]     rval = self.evaluate_expr0( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1209, in evaluate_expr0
>     [junit]     rval = self.evaluate_expr1( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1232, in evaluate_expr1
>     [junit]     rval = self.evaluate_expr2( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1255, in evaluate_expr2
>     [junit]     rval = self.evaluate_expr3( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1276, in evaluate_expr3
>     [junit]     rval = self.evaluate_expr4( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1297, in evaluate_expr4
>     [junit]     rval = self.evaluate_expr5( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1319, in evaluate_expr5
>     [junit]     rval = self.evaluate_expr6( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1364, in evaluate_expr6
>     [junit]     rval = self.evaluate_expr7( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1424, in evaluate_expr7
>     [junit]     rval = self.evaluate_expr8( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1460, in evaluate_expr8
>     [junit]     rval = self.evaluate_expr9( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1599, in evaluate_expr9
>     [junit]     rval = self.evaluate_expr10( context, place, parse_only )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 1709, in evaluate_expr10
>     [junit]     reference_object = reference_object.call( arguments, context )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\Javascript.py", line 582, in call
>     [junit]     return self.dereference().call(argset,context)
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 1448, in call
>     [junit]     self.form_instance.submit( )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 754, in submit
>     [junit]     self.window_instance.execute_action( self.method, variables, files, self.action_url )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 1021, in execute_action
>     [junit]     return self.browser_instance.execute_action( self.window_name, method, parameters, files, self.resolve( url ) )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 1160, in execute_action
>     [junit]     window_data = self.fetch_data_with_multipart_post( parameters, files, url )
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 1235, in fetch_data_with_multipart_post
>     [junit]     return self.talk_to_server(url, method="POST", content_type=content_type, body=body)
>     [junit]   File "D:\code\manifoldcf_trunk\connectors\kafka\test-HSQLDB-output\VirtualBrowser.py", line 1324, in talk_to_server
>     [junit]     raise Exception("Received an error response %d from url: '%s'" % (status,url) )
>     [junit] Exception: Received an error response 500 from url: 'http://localhost:8346/mcf-crawler-ui/execute.jsp'
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [main] INFO org.eclipse.jetty.server.ServerConnector - Stopped ServerConnector@7857fe2{HTTP/1.1}{0.0.0.0:8346}
>     [junit] [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Stopped o.e.j.w.WebAppContext@2e222612{/mcf-api-service,file:/C:/Users/Markus/AppData/Local/Temp/jetty-0.0.0.0-8346-mcf-api-service.war-_mcf-api-service-any-7710121541795189855.dir/webapp/,UNAVAILABLE}{D:\code\manifoldcf_trunk\dist/web/war/mcf-api-service.war}
>     [junit] [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Stopped o.e.j.w.WebAppContext@3246fb96{/mcf-authority-service,file:/C:/Users/Markus/AppData/Local/Temp/jetty-0.0.0.0-8346-mcf-authority-service.war-_mcf-authority-service-any-3957204946994965733.dir/webapp/,UNAVAILABLE}{D:\code\manifoldcf_trunk\dist/web/war/mcf-authority-service.war}
>     [junit] [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Stopped o.e.j.w.WebAppContext@77eca502{/mcf-crawler-ui,file:/C:/Users/Markus/AppData/Local/Temp/jetty-0.0.0.0-8346-mcf-crawler-ui.war-_mcf-crawler-ui-any-8910054509415332620.dir/webapp/,UNAVAILABLE}{D:\code\manifoldcf_trunk\dist/web/war/mcf-crawler-ui.war}
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.common.network.Selector - Error in I/O with localhost/127.0.0.1
>     [junit] java.net.ConnectException: Connection refused: no further information
>     [junit]     at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>     [junit]     at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>     [junit]     at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
>     [junit]     at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
>     [junit]     at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
>     [junit]     at java.lang.Thread.run(Thread.java:745)
>     [junit] ------------- ---------------- ---------------
>     [junit] Testcase: createConnectionsAndJob(org.apache.manifoldcf.agents.output.kafka.NavigationHSQLDBUI):    Caused an ERROR
>     [junit] UI test failed; error code: 1
>     [junit] java.lang.Exception: UI test failed; error code: 1
>     [junit]     at org.apache.manifoldcf.core.tests.HTMLTester.executeTest(HTMLTester.java:184)
>     [junit]     at org.apache.manifoldcf.agents.output.kafka.NavigationHSQLDBUI.createConnectionsAndJob(NavigationHSQLDBUI.java:222)
>     [junit]
>     [junit]
> BUILD FAILED
> D:\code\manifoldcf_trunk\build.xml:489: The following error occurred while executing this line:
> D:\code\manifoldcf_trunk\build.xml:427: The following error occurred while executing this line:
> D:\code\manifoldcf_trunk\dist\connector-build.xml:1180: Test org.apache.manifoldcf.agents.output.kafka.NavigationHSQLDBUI failed
> Total time: 8 minutes 35 seconds
> D:\code\manifoldcf_trunk>
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)