You need to enable JavaScript to run this app.
导航
查看 Group 消费状态
最近更新时间:2024.07.02 14:33:33首次发布时间:2022.03.05 11:34:49

成功创建 Group 并启动消费之后,消息队列 RocketMQ版会记录并在控制台展示消费的相关信息,例如消费速度等基础消费信息、客户端IP等客户端信息、订阅的 Topic 等订阅信息。

操作入口

  1. 登录消息队列 RocketMQ版控制台
  2. 在顶部菜单栏中选择地域。
  3. 实例列表中找到指定 RocketMQ 实例,并单击实例名称。
  4. Group管理页面单击指定 Group ID。
  5. 分别查看消费信息、客户端信息和订阅信息。
    图片

查看消费信息

消费信息区域展示消费的整体状态、消息堆积量等信息。

展示项

说明

消费状态

当前的消费状态,即消费中未消费

消息堆积量

该 Group ID 下消费者实例群组的未消费消息的总量。
此处显示的消息堆积量为未过滤 Tag 的总堆积量,包括 Topic 下所有 Tag 的消息。

消费模式

消费的模式。默认为集群模式,您也可以在 Consumer 客户端中指定消费模式为广播模式。
请勿在同一 Group 下同时配置集群模式和广播模式。

实时消费速度

该 Group 下消费者实例群组接收消息的总 TPS,单位为条/秒。

消息延迟时间

该 Group 下消费者实例群组最早的一条未消费消息的生产时间与当前时间的差值。

订阅关系

该 Group 下消费者实例群组的订阅关系是否一致。

是否顺序消费

服务端将消息投递给消费者消费的顺序。

  • 是:顺序投递
  • 否:并发投递

说明

仅 5.x 版本支持是否顺序消费最大重试次数。消息队列 RocketMQ版的 5.x 版本目前处于白名单开放状态,如需使用,请联系技术支持申请开白。

最大重试次数

消息可以重新被投递的最大次数。超过最大重试次数还没被成功消费,消息将被投递至死信队列或丢弃。

查看客户端信息

客户端信息页签中,可以查看使用当前 Group 的 Consumer 客户端列表,其中包括客户端的 IP、ID、语言、版本等信息。

展示项

说明

客户端IP

Consumer 客户端的IP地址及端口号。

客户端ID

Consumer 客户端的 ID,即默认的 Client ID,或用户调用客户端 API 时设置的 Client ID。

客户端语言

该客户端的使用的开发语言。

客户端版本

该客户端的 RocketMQ 版本。

消息堆积量

该客户端未消费的消息量。

在指定客户端对应的操作列单击消费详情,可以查看该客户端的消费数据,包括当前客户端的基本信息、消费统计信息和重试消费统计信息。

  • 基本信息区域展示当前客户端的 IP、开发语言及客户端版本。
  • 消费统计页签展示当前客户端的消费统计信息,包括订阅的 Topic 名称、消费成功(条/秒)、消费失败(条/秒)、业务处理时间(毫秒/条)和未消费消息数。
  • 重试消费统计页签展示当前客户端消费失败时,重试消费的相关统计信息,包括 Topic 名称、消费成功(条/秒)、消费失败(条/秒)、业务处理时间(毫秒/条)和未消费消息数。

查看 Group 的订阅信息

订阅信息页签中,可以查看当前 Group 所订阅的 Topic 列表,其中包括 Topic 的名称、队列个数。

展示项

说明

Topic

客户端订阅的 Topic 名称。

队列个数

Topic 对应的队列数。每个 Topic 下有一到多个队列用于存储消息。

在指定 Topic 对应的操作列单击队列消费详情,可以查看指定 Topic 每个队列的消费进度等信息,其中包括指定 Topic 的队列总数、Topic 名称、消费组 GroupID,并以表格形式展示每个队列的消费详情。

展示项

说明

队列ID

队列的唯一标识。

最大偏移量

该队列最新一条消息的位点。

当前消费进度

该队列当前的消费位点。

未消费消息数

该队列中未消费的消息数量。

当前消费进度时间戳

该队列最近一次消费行为的时间戳。

在操作列单击重置消费位点,可以通过不同方式重置当前 Topic 的消费位置,重置方式的详细说明请参考重置消费位点