通过查看 Topic 的订阅 Group,您可以了解订阅了该 Topic 的所有 Group 的订阅状态,包括 Group 列表、在线状态及消息堆积情况等。通过这些信息,您可以确认消息是否被正常消费、及时发现无 Group 订阅的异常 Topic,并评估业务变更的影响范围。
查看订阅的 Group
1. 登录 TDMQ RocketMQ 版控制台。
2. 在左侧导航栏选择资源管理 > 集群管理,选择好地域后,单击目标集群的“ID”,进入集群基本信息页面。
3. 在集群基本信息页面,选择 Topic 页签,单击目标 Topic 名称,选择订阅 Group页签,展示订阅该 Topic 的 Group 信息。
参数名称 | 含义与说明 |
Group 名称 | 消费者组(Consumer Group)的唯一标识。组内所有消费者共同消费同一个 Topic 的消息,实现负载均衡。 |
状态 | 消费者组的当前状态,通常为在线或离线,离线状态表示该组内没有任何运行的消费者实例。 |
消费模式 | 分为集群消费和广播消费。 集群消费:一条消息只会被组内的一个消费者消费。 广播消费:一条消息会被组内的每一个消费者消费一次。 |
协议类型 | 消费者使用的通信协议,如 TCP 和 HTTP 等,决定了客户端与 Broker 的交互方式。 |
过滤类型 | 消息过滤的方式。主要为 TAG 或 SQL92。 TAG:通过消息的标签进行简单匹配。 SQL92:通过自定义的 SQL 表达式对消息属性进行复杂过滤。 |
过滤规则 | 具体执行的过滤条件。例如在 TAG 模式下可能是 TagA,在 SQL92 模式下可能是 a > 5。 |
消息堆积数量 | 该消费者组尚未消费的消息总量,是衡量消费健康度的关键指标,堆积持续增长意味着消费速度跟不上生产速度。 |
消费进度更新时间 | 该消费者组的消费进度(offset)最后一次被提交到 Broker 的时间,反映了消费端的活跃度,长时间未更新可能意味着消费者已僵死或停止。 |
操作 | 如果当前 Topic 下的 Group 处于离线状态(即没有在线客户端),则可以在操作列单击取消订阅以清理历史订阅关系数据,避免历史脏数据的影响。 |