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

《Kafka1.0.0如何查看队列消费进度》 查询结果

当然,这种方法是针对高级级kafka读取api,因为高级级api需要按照group中的consumer按照offset来读取数据,并且所有维护offset信息都保存在zookeeper中。但是低级api不需要group,offset由consumer自行维护,所以针对这类topic用户是没法使用这个命令读取结果的。

    原文作者:蠟筆小噺没有烦恼
    原文地址: https://www.jianshu.com/p/b436cf703e54
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞