大佬,我的kafka是0.9.0版本,那天消费突然卡住,我想查看offset消费到哪里,却发现没有 bin目录下没有kafka-consumer-groups.sh。这要怎么办? 我想看看是不是offset没有变动,lag有没有增大,以及想知道offset卡住的原因,我看到消费端程序提交offset是有报错日志的。 第一我想查看offset这个group消费情况,第二我想请问这种情况怎么解决啊?是重启kafka消费端吗?
可以用:
## 显示某个消费组的消费详情(仅支持offset存储在zookeeper上的) bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group test
参考:kafka命令大全
谢谢大佬!
你的答案