Hi,
I recently got the kafka single node cluster in docker container
I am trying to get data feed for druid realtime node that has the spec defined to talk to zookeeper endpoint.
But see below exception
Aug 10 20:57:46 sjc-wasl-stats1 druid[45493]: 2018-08-10T20:57:46,633 INFO [druid-artifactory-requests_sjc-wasl-stats1-1533930480817-ae2fcc24-leader-finder-thread] kafka.producer.SyncProducer - Connected to kafka1:9092 for producing
Aug 10 20:57:46 sjc-wasl-stats1 druid[45493]: 2018-08-10T20:57:46,633 INFO [druid-artifactory-requests_sjc-wasl-stats1-1533930480817-ae2fcc24-leader-finder-thread] kafka.producer.SyncProducer - Disconnecting from kafka1:9092
Aug 10 20:57:46 sjc-wasl-stats1 druid[45493]: 2018-08-10T20:57:46,633 WARN [druid-artifactory-requests_sjc-wasl-stats1-1533930480817-ae2fcc24-leader-finder-thread] kafka.client.ClientUtils$ - Fetching topic metadata with correlation id 20331 for topics [Set(log.artifactory.json.request_log)] from broker [id:1,host:kafka1,port:9092] failed
Aug 10 20:57:46 sjc-wasl-stats1 druid[45493]: java.nio.channels.ClosedChannelException
Aug 10 20:57:46 sjc-wasl-stats1 druid[45493]: at kafka.network.BlockingChannel.send(BlockingChannel.scala:100) ~[kafka_2.10-0.8.2.1.jar:?]
Aug 10 20:57:46 sjc-wasl-stats1 druid[45493]: at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:73) ~[kafka_2.10-0.8.2.1.jar:?]
Aug 10 20:57:46 sjc-wasl-stats1 druid[45493]: at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:72) ~[kafka_2.10-0.8.2.1.jar:?]
Aug 10 20:57:46 sjc-wasl-stats1 druid[45493]: at kafka.producer.SyncProducer.send(SyncProducer.scala:113) ~[kafka_2.10-0.8.2.1.jar:?]
Aug 10 20:57:46 sjc-wasl-stats1 druid[45493]: at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:58) [kafka_2.10-0.8.2.1.jar:?]
Aug 10 20:57:46 sjc-wasl-stats1 druid[45493]: at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:93) [kafka_2.10-0.8.2.1.jar:?]
Aug 10 20:57:46 sjc-wasl-stats1 druid[45493]: at kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:66) [kafka_2.10-0.8.2.1.jar:?]
Aug 10 20:57:46 sjc-wasl-stats1 druid[45493]: at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:60) [kafka_2.10-0.8.2.1.jar:?]
Aug 10 20:57:46 sjc-wasl-stats1 druid[45493]: 2018-08-10T20:57:46,633 INFO [druid-artifactory-requests_sjc-wasl-stats1-1533930480817-ae2fcc24-leader-finder-thread] kafka.producer.SyncProducer - Disconnecting from kafka1:9092
Aug 10 20:57:46 sjc-wasl-stats1