按照网上的方法尝试了./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper **:2181 --group ** --topic **
发现并不管用,查看了kafka 的jar包,貌似ConsumerOffsetChecker 类已经被移除,上github上看了下kafka的源码,告知我:
The kafka-consumer-offset-checker.sh (kafka.tools.ConsumerOffsetChecker) has been deprecated. Going forward, please use kafka-consumer-groups.sh
不管是kafka-consumer-offset-checker.sh脚本还是run-class.sh kafka.tools.ConsumerOffsetChecker都已经失效,可以使用kafka-consumer-groups.sh。
使用如下配置:
bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group my-group
当然,这种方法是针对高级级kafka读取api,因为高级级api需要按照group中的consumer按照offset来读取数据,并且所有维护offset信息都保存在zookeeper中。但是低级api不需要group,offset由consumer自行维护,所以针对这类topic用户是没法使用这个命令读取结果的。