前言
本文提供2种查看消息堆积的情况:
- 前端控制台查看
- mqadmin命令查看
以及查询过程中出现的问题和解决方案
第一种查看方式 console
1、登录控制台后,依次点击 Topic -> CONSUMER MANAGE
打开就可以看到消息挤压情况了
说明:
- Broker : broker名称
- Queue : 队列名称
- consumerClient : 消费者客户端;(必须启动消费者后才看得到信息)
- brokerOffset: broker中消息的偏移量,从1开始,表示生产者发送的消息数量
- consumerOffset :消费者已经消费的偏移量,从1开始,表示消费者已经消费的数量
- diffTotal : 差值,表示还有多少未消费的消息;
第二种查看方式 mqadmin
查看所有消费组group
# -n 后面是nameserver的ip和端口
sh mqadmin consumerProgress -n 192.168.31.250:9876
查看消费挤压情况
必须先启动消费者才能查询,否则报错
# -g 后面是消费组的名称
sh mqadmin consumerProgress -n 192.168.31.250:9876 -g device-log-group
说明:
- Topic :主题名称
- Broker Name: broker节点名称
- QID : 队列id,从0开始
- brokerOffset: broker中消息的偏移量,从1开始,表示生产者发送的消息数量
- consumerOffset :消费者已经消费的偏移量,从1开始,表示消费者已经消费的数量
- diff : 差值,表示还有多少未消费的消息;
错误解决
若你的消费者未启动,会报错:MQClientException: CODE: 206 DESC: Not found the consumer group consume stats, because return offset table is empty, maybe the consumer not consume any message
;
所以,必须先启动消费者才能进行查询