Kafka1.0.0如何查看队列消费进度

按照网上的方法尝试了./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用户是没法使用这个命令读取结果的。