设为首页 加入收藏

TOP

kafka查询最新producer offset的命令
2019-01-21 02:27:26 】 浏览:317
Tags:kafka 查询 最新 producer offset 命令

--查看topic消费进度(不是consumer的offset)
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list node1:9092,node2:9092,node3:9092 --topic mytopic --time -1
-1表示查询 mytopic 各个分区当前最大的消息位移值(注意,这里的位移不是consumer端的位移,而是指消息在每个分区的位置)

如果你要查询曾经生产过的最大消息数,那么只运行上面这条命令然后把各个分区的结果相加就可以了。

但如果你需要查询当前集群中该topic的消息数,那么还需要运行下面这条命令:
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list node1:9092,node2:9092,node3:9092 --topic mytopic --time -2
-2表示去获取当前各个分区的最小位移。之后把运行第一条命令的结果与刚刚获取的位移之和相减就是集群中该topic的当前消息总数。

】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇kafka consumer zookeeper 交互逻.. 下一篇java Kafka 简单应用实例

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目