成功创建 Group 并启动消费之后,消息队列 RocketMQ版会记录并在控制台展示消费的相关信息,例如消费速度等基础消费信息、客户端IP等客户端信息、订阅的 Topic 等订阅信息。
消费信息区域展示消费的整体状态、消息堆积量等信息。
展示项 | 说明 |
---|---|
消费状态 | 当前的消费状态,即消费中或未消费。 |
消息堆积量 | 该 Group ID 下消费者实例群组的未消费消息的总量。 |
消费模式 | 消费的模式。默认为集群模式,您也可以在 Consumer 客户端中指定消费模式为广播模式。 |
实时消费速度 | 该 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 版本。 |
消息堆积量 | 该客户端未消费的消息量。 |
在指定客户端对应的操作列单击消费详情,可以查看该客户端的消费数据,包括当前客户端的基本信息、消费统计信息和重试消费统计信息。
在订阅信息页签中,可以查看当前 Group 所订阅的 Topic 列表,其中包括 Topic 的名称、队列个数。
展示项 | 说明 |
---|---|
Topic | 客户端订阅的 Topic 名称。 |
队列个数 | Topic 对应的队列数。每个 Topic 下有一到多个队列用于存储消息。 |
在指定 Topic 对应的操作列单击队列消费详情,可以查看指定 Topic 每个队列的消费进度等信息,其中包括指定 Topic 的队列总数、Topic 名称、消费组 GroupID,并以表格形式展示每个队列的消费详情。
展示项 | 说明 |
---|---|
队列ID | 队列的唯一标识。 |
最大偏移量 | 该队列最新一条消息的位点。 |
当前消费进度 | 该队列当前的消费位点。 |
未消费消息数 | 该队列中未消费的消息数量。 |
当前消费进度时间戳 | 该队列最近一次消费行为的时间戳。 |
在操作列单击重置消费位点,可以通过不同方式重置当前 Topic 的消费位置,重置方式的详细说明请参考重置消费位点。