You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Chris Barlock <ba...@us.ibm.com> on 2016/06/20 23:51:16 UTC

Something Bad Happened

I started getting the following errors on all topics:

root@kafka-1-bw3ys:/opt/kafka/bin# ./kafka-console-consumer.sh --topic 
systemconfig --from-beginning --zookeeper $ZOOKEEPER_URL
[2016-06-20 23:43:27,460] WARN Fetching topic metadata with correlation id 
0 for topics [Set(systemconfig)] from broker 
[id:1,host:10.0.0.188,port:9092] failed (kafka.client.ClientUtils$)
java.io.EOFException: Received -1 when reading from channel, socket has 
likely been closed.
        at kafka.utils.Utils$.read(Utils.scala:381)
        at 
kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
        at 
kafka.network.Receive$class.readCompletely(Transmission.scala:56)
        at 
kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
        at 
kafka.network.BlockingChannel.receive(BlockingChannel.scala:111)
        at 
kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:75)
        at 
kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:72)
        at kafka.producer.SyncProducer.send(SyncProducer.scala:113)
        at 
kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:58)
        at 
kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:93)
        at 
kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:66)
        at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:60)
[2016-06-20 23:43:27,464] WARN 
[console-consumer-58602_kafka-1-bw3ys-1466466206807-f78e50cd-leader-finder-thread], 
Failed to find leader for Set([systemconfig,1], [systemconfig,3], 
[systemconfig,0], [systemconfig,2], [systemconfig,4]) 
(kafka.consumer.ConsumerFetcherManager$LeaderFinderThread)
kafka.common.KafkaException: fetching topic metadata for topics 
[Set(systemconfig)] from broker 
[ArrayBuffer(id:1,host:10.0.0.188,port:9092)] failed
        at 
kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:72)
        at 
kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:93)
        at 
kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:66)
        at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:60)
Caused by: java.io.EOFException: Received -1 when reading from channel, 
socket has likely been closed.
        at kafka.utils.Utils$.read(Utils.scala:381)
        at 
kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
        at 
kafka.network.Receive$class.readCompletely(Transmission.scala:56)
        at 
kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
        at 
kafka.network.BlockingChannel.receive(BlockingChannel.scala:111)
        at 
kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:75)
        at 
kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:72)
        at kafka.producer.SyncProducer.send(SyncProducer.scala:113)
        at 
kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:58)
        ... 3 more

This is with Kafka 0.8.2.1, but it also happens with 0.10.0.0.  Kafka and 
ZooKeeper are running in separate Docker containers.  I'm leaning toward a 
problem with my environment, but would love suggestions as to what might 
be causing this.

Thanks!

Chris