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:监控消费者和延迟的队列