rocketmq 查看消息堆积情况

发布时间:2022-08-03 13:46:24 作者:yexindonglai@163.com 阅读(11214)

前言

本文提供2种查看消息堆积的情况:

  • 前端控制台查看
  • mqadmin命令查看

以及查询过程中出现的问题和解决方案

第一种查看方式 console

1、登录控制台后,依次点击 Topic -> CONSUMER MANAGE

打开就可以看到消息挤压情况了

说明:

  • Broker : broker名称
  • Queue : 队列名称
  • consumerClient : 消费者客户端;(必须启动消费者后才看得到信息)
  • brokerOffset: broker中消息的偏移量,从1开始,表示生产者发送的消息数量
  • consumerOffset :消费者已经消费的偏移量,从1开始,表示消费者已经消费的数量
  • diffTotal : 差值,表示还有多少未消费的消息;

第二种查看方式 mqadmin

查看所有消费组group

  1. # -n 后面是nameserver的ip和端口
  2. sh mqadmin consumerProgress -n 192.168.31.250:9876

查看消费挤压情况
必须先启动消费者才能查询,否则报错

  1. # -g 后面是消费组的名称
  2. 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;
所以,必须先启动消费者才能进行查询

关键字消息队列