kafka 积压消息查询
•
大数据
1 查询kafka位置
find / -name kafka find / -name kafka-consumer-groups.sh
在目录下,执行下面的脚本,查询kafka积压消息
2 查询消费者组
./kafka-consumer-groups.sh --bootstrap-server 192.168.xx.xx:9097 --list

3 查询消费者组详情
./kafka-consumer-groups.sh --bootstrap-server 192.168.xx.xx:9097 --describe --group groupname

4 查询topic当前消费偏移值
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.xx.xx:9097 --topic topicname --partitions 0
5 通过Offset Explore工具查询当前offset值

本文来自网络,不代表协通编程立场,如若转载,请注明出处:https://net2asp.com/f98bb63918.html
