kafka使用python脚本配置lag监控,批量查询lag时报异常

最爱的猪 发表于: 2021-05-11   最后更新时间: 2021-05-12 00:06:59   1,867 游览

原先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

跪求大神帮忙看看问题,万分感谢!

发表于 2021-05-11

这个版本确实有这个问题,而且还未解决,建议你升级kafka。
https://issues.apache.org/jira/browse/KAFKA-6856

最爱的猪 -> 半兽人 3年前

您好,请问,对于这个问题,使用JAVA API也存在的吧?我写的代码会出现空指针报错:

java.lang.NullPointerException
    at pers.xmr.bigdata.kafka.KafkaOffsetTools.main(KafkaOffsetTools.java:69)
半兽人 -> 最爱的猪 3年前

一样的,命令行会去掉底层调用底层的实现。

你的答案

查看kafka相关的其他问题或提一个您自己的问题