0


kafka 积压消息查询

1 查询kafka位置

  1. find / -name kafka
  2. find / -name kafka-consumer-groups.sh

在目录下,执行下面的脚本,查询kafka积压消息

2 查询消费者组

  1. ./kafka-consumer-groups.sh --bootstrap-server 192.168.xx.xx:9097 --list

在这里插入图片描述

3 查询消费者组详情

  1. ./kafka-consumer-groups.sh --bootstrap-server 192.168.xx.xx:9097 --describe --group groupname

在这里插入图片描述

4 查询topic当前消费偏移值

  1. ./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 积压消息查询”的评论:

还没有评论