消息队列 RocketMQ 版 查看 Topic 订阅关系

通过查看 Topic 的订阅 Group,可以以了解订阅了该 Topic 的所有 Group 的订阅状态,包括 Group 列表、在线状态及消息堆积情况等。通过这些信息,可以以确认消息是否被正常消费、及时发现无 Group 订阅的异常 Topic,并评估业务变更的影响范围。

相关产品
消息队列 RocketMQ 版 产品页,含版本规格、价格与购买入口。

一、查看订阅的 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 处于离线状态(即没有在线客户端),则可以在操作列单击取消订阅以清理历史订阅关系数据,避免历史脏数据的影响。
赞 (0)
上一篇 4天前
下一篇 4天前