如遇消息消费异常,可在消息队列RocketMQ版控制台查看消费者状态初步诊断原因。您可查看每个Group ID代表的消费者实例群组的信息,也可查看该群组下单个消费者实例的信息。

应用场景

消费者状态信息包括在线状态、订阅关系、消费TPS、消息堆积量和线程堆栈信息等,经常被应用于以下故障排查场景:

  • 订阅关系不一致
    • 现象:在Group 详情页面,看到Group ID的订阅关系显示订阅关系不一致,请尽快处理!
    • 处理:订阅关系不一致的处理方法,请参见订阅关系不一致
  • 消息堆积
    • 现象:在Group 详情页面,看到Group ID的实时消息堆积量的值高于预期。
    • 处理:处理消息堆积的具体办法,请参见如何处理消息堆积

查看Group ID综合信息

请按以下步骤查看Group ID所代表的消费者实例集群的综合信息:

  1. 登录消息队列RocketMQ版控制台
  2. 在左侧导航栏,单击实例列表
  3. 在顶部菜单栏,选择地域,如华东1(杭州)
  4. 实例列表页面,找到目标实例,在其操作列单击更多,然后在下拉菜单中选择Group 管理
  5. Group 管理页面,找到要查看的Group ID,在其操作列单击详情

    查看结果如下图所示。

    consumer_states
表 1. 字段说明
字段/图标 说明
消费者状态
  • 只要该Group ID下有一个消费者实例在线,就显示在线,此时您可以看到页面下方的客户端连接信息区域显示了在线的消费者实例信息;
  • 若该Group ID下所有消费者实例都不在线,则显示离线,且客户端连接信息区域无信息显示。
订阅关系是否一致 显示该Group ID下消费者实例群组的订阅关系是否一致。订阅关系一致的概念请参见订阅关系一致
实时消费速度 该Group ID下消费者实例群组接收消息的总TPS,单位为条/秒。
实时消息堆积量 该Group ID下消费者实例群组的未消费消息的总量。
最近消费时间 该Group ID下消费者实例群组最近一次消费消息的时间。
消息延迟时间 该Group ID下消费者实例群组最早的一条未消费消息的生产时间与当前时间的差值。

查看Group ID消费者实例的信息

若此时该Group ID的在线状态为在线,则在客户端连接信息区域您可以查看此时在线的每个消费者实例的具体信息,包括客户端IP、宿主机IP/公网IP、客户端信息和消息堆积量等。

查看更多详细信息

除上述信息,还可在某个消费者实例信息右侧的操作列,单击更多数据查看更多详细信息,包括消费统计、重试消费统计和客户端堆栈信息等,如下图所示。

more_detialmore_detial查看Group ID的报警信息

如需查看该Group ID的报警监控状态,可以在页面下方选择云监控,展现的信息如下图所示。

cloud_monitior查看Group ID的消息消费数据

如需查看该Group ID在所订阅的Topic中的消息消费总量和消息消费TPS。可以在页面下方选择消息消费图表,展现的信息如下图所示。

message_consumer_table

更多信息

如果您设置过监控项,且接收到消息堆积告警通知,请参见使用消息队列RocketMQ版后收到消息堆积告警处理。