ConsumerBalanceFailedException与kafka控制台使用者

os8fio9y  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(262)

我刚刚安装了kafka 0.9.0.1,在启动kafka控制台使用者时出现以下错误:

$ bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic myrandomtesttopic --from-beginning
[2016-03-30 15:46:17,568] ERROR Unknown error when running consumer:  (kafka.tools.ConsoleConsumer$)
kafka.common.ConsumerRebalanceFailedException: console-consumer-84710_stg02-1459349168698-425dcf53 can't rebalance after 4 retries
at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:660)
at kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:967)
at kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.<init>(ZookeeperConsumerConnector.scala:1001)
at kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:163)
at kafka.consumer.OldConsumer.<init>(BaseConsumer.scala:75)
at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:63)
at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:47)
at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)

logs/zookeeper.out 只有:

[2016-03-30 15:46:17,902] WARN caught end of stream exception (org.apache.zookeeper.server.NIOServerCnxn)
EndOfStreamException: Unable to read additional data from client sessionid 0x153c7e67216000e, likely client has closed socket
at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228)
at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208)
at java.lang.Thread.run(Thread.java:745)
[2016-03-30 15:46:17,903] INFO Closed socket connection for client /127.0.0.1:8857 which had sessionid 0x153c7e67216000e (org.apache.zookeeper.server.NIOServerCnxn)
[...]

你知道这是怎么回事吗-\

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题