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值