获取topic当前消息数

柔光的暖阳◎ 2022-10-24 05:58 164阅读 0赞

创建测试 topic:  
bin/kafka-topics.sh -zookeeper localhost:2181 --create --partitions 5 --replication-factor 1 --topic test765

生产测试消息:  
为 topic test765 生产 500000 条消息：  
bin/kafka-producer-perf-test.sh --topic test765 --throughput -1 --record-size 10 --num-records 500000 --producer-props bootstrap.servers=localhost:9092

获取 topic 消息数:  
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test765 --time -1

# 输出信息 #

test765:0:100000  
test765:1:100000  
test765:2:100000  
test765:3:100000  
test765:4:100000

bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test765 --time -2

# 输出信息 #

test765:0:0  
test765:1:0  
test765:2:0  
test765:3:0  
test765:4:0

–time-1 表示要获取指定topic所有分区当前的最大位移，–time-2 表示获取当前最早位移。

两个命令的输出结果相减便可得到所有分区当前的消息总数。

分区当前的消息总数 = \[–time-1\] - \[–time-2\]

相减是因为随着 kafka 的运行，topic 中有的消息可能会被删除，，因此 --time-1 的结果其实表示的是历史上该topic生产的最大消息数，如果用户要统计当前的消息总数就必须减去 --time-2 的结果。

本例中没有任何消息被删除，故 --time-2 的结果全是0，表示最早位移都是0，消息总数等于历史上发送的消息总数。

获取topic当前消息数

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 JMS 开发步骤、持久化 topic 消息与非持久化 topic 消息

相关 Java获取当前秒数

相关获取table当前点击的行数

相关 java获取当前月的天数、java获取当前月每天的日期

相关 java获取 oracle连接数_查看oracle当前连接数

相关获取topic当前消息数

相关 JS获取当前日期的毫秒数方式

相关 2.4、使用 JmsTemplate 向 ActiveMQ 发送和获取 Topic 类型消息

相关 Kafka如何获取topic最近n条消息

相关获取当前时间以及毫秒数