当前位置:  开发笔记 > 编程语言 > 正文

偏移量存储为Kafka时如何检查消费者偏移量?

如何解决《偏移量存储为Kafka时如何检查消费者偏移量?》经验,为你挑选了1个好方法。

从0.8.1.1版本中,卡夫卡提供了计提卡夫卡偏移的存储,而不是动物园管理员(见本)。我无法弄清楚如何检查所消耗补偿的细节,因为目前的工具只能提供给仅供饲养员消费者偏移计数检查。(我指的是这个)

如果有任何工具可用来检查消费者的抵销,请告知我。



1> codejitsu..:

I'am using kafka 0.8.2 with offsets stored in kafka. This tools works good for me:

./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker 
        --topic your-topic 
        --group your-consumer-group
        --zookeeper localhost:2181

You get all informations you need: topic size, consumer lag, owner.

推荐阅读
mobiledu2402852357
这个屌丝很懒,什么也没留下!
DevBox开发工具箱 | 专业的在线开发工具网站    京公网安备 11010802040832号  |  京ICP备19059560号-6
Copyright © 1998 - 2020 DevBox.CN. All Rights Reserved devBox.cn 开发工具箱 版权所有