原先kafka0.9没有问题,使用的语句是
kafka-run-class.bat kafka.tools.ConsumerOffsetChecker --zookeeper zookeeper1:2181,zookeeper2:2181,zookeeper3:2181 --topic topic --group group
升级成kafka1.0.1后,使用的语句是
kafka-consumer-groups.bat --bootstrap-server broker1:9092,broker2:9092,broker3:9092,broker4:9092 --group group --describe
使用脚本批量查询时会随机出现报错,单个语句执行的时候又是正常的。
Error: Executing consumer group command failed due to The consumer group command timed out while waiting for group to initialize
跪求大神帮忙看看问题,万分感谢!
这个版本确实有这个问题,而且还未解决,建议你升级kafka。
https://issues.apache.org/jira/browse/KAFKA-6856
感谢
您好,请问,对于这个问题,使用JAVA API也存在的吧?我写的代码会出现空指针报错:
java.lang.NullPointerException at pers.xmr.bigdata.kafka.KafkaOffsetTools.main(KafkaOffsetTools.java:69)
一样的,命令行会去掉底层调用底层的实现。
你的答案