Kafka查看消息是否堆积（服务器）

查询消费组

先进入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 分区号