Skip to content

Instantly share code, notes, and snippets.

@goaquin
Created February 10, 2017 21:03
Show Gist options
  • Save goaquin/480d502707a70e048ef87d435d066d78 to your computer and use it in GitHub Desktop.
Save goaquin/480d502707a70e048ef87d435d066d78 to your computer and use it in GitHub Desktop.
[2017-02-10 18:01:58,136] WARN [console-consumer-27843_levante.akainix.local-1486760513998-4b888027-leader-finder-thread], Failed to find leader for Set([telegraf,0]) (kafka.consumer.ConsumerFetcherManager$LeaderFinderThread)
kafka.common.KafkaException: fetching topic metadata for topics [Set(telegraf)] from broker [ArrayBuffer(BrokerEndPoint(186,192.168.70.5:9092,9092))] failed
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:73)
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:94)
at kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:66)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)
Caused by: java.nio.channels.ClosedChannelException
at kafka.network.BlockingChannel.send(BlockingChannel.scala:110)
at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:80)
at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:79)
at kafka.producer.SyncProducer.send(SyncProducer.scala:124)
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
... 3 more
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment