0


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值

在这里插入图片描述

标签: kafka

本文转载自: https://blog.csdn.net/zoujian1991/article/details/130342320
版权归原作者 SuperAlive 所有, 如有侵权,请联系我们删除。

“kafka 积压消息查询”的评论:

还没有评论