查询消费组
先进入kafka中的bin目录
./kafka-consumer-groups.sh --bootstrap-server ip:9092 --list
查询消费组的消费情况
./kafka-consumer-groups.sh --bootstrap-server ip1:9092 --describe --group 组名称
解析
- TOPIC :topic消息队列id
- CURRENT-OFFSET :当前消费的偏移量
- LAG:消息堆积数量
查看分区中消息偏移量
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list ip1:9092 --topic topic名称 --partitions 分区号
来源地址:https://blog.csdn.net/Li_games/article/details/130337368