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