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

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Kafka1.0.0如何查看队列消费进度相关的知识,希望对你有一定的参考价值。

参考技术A 按照网上的方法尝试了./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper **:2181 --group ** --topic **

发现并不管用,查看了kafka 的jar包,貌似ConsumerOffsetChecker 类已经被移除,上github上看了下kafka的源码,告知我:

不管是kafka-consumer-offset-checker.sh脚本还是run-class.sh kafka.tools.ConsumerOffsetChecker都已经失效,可以使用kafka-consumer-groups.sh。

使用如下配置:

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

以上是关于Kafka1.0.0如何查看队列消费进度的主要内容,如果未能解决你的问题,请参考以下文章

RocketMQ是是如何管理消费进度的?又是如何保证消息成功消费的?

加米谷:Kafka OffsetMonitor:监控消费者和延迟的队列

高并发系统设计(十五):消息队列如何降低消息队列系统中消息的延迟?

kafka查看队列的消费情况

kafka1.0.0集群搭建

如何查看pod install进度