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

Topic 的订阅关系展示了当前所有消费者组的订阅状态,包括消费组列表、在线状态及分区分配情况。通过查看这些信息,可以以确认消息是否被正常消费、及时发现无消费者订阅的异常 Topic,并评估业务变更的影响范围。这里说明通过 CKafka 控制台查看 Topic 订阅关系操作步骤。

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

一、操作步骤

1. 登录 CKafka 控制台。

2. 在左侧导航栏单击实例列表,单击目标实例的“ID/名称”,进入实例详情页。

3. 在实例详情页,单击 Topic列表页签,在 Topic 列表页面,单击操作栏的更多 > 订阅关系,可查看订阅该 Topic 的消费组信息,并进行消费组的 offset 设置和查看消费组详情。

参数 说明
消费组名称 订阅该 Topic 的消费组名称。
状态 消费组当前的状态。Dead:消费组内没有任何成员,且没有任何元数据。Empty:消费组内没有任何成员,存在元数据。如果组内所有 offset 都已过期,则会变为 Dead 状态。一般新创建的 Group 默认为 Empty 状态。说明:如果消费组内的所有消费者都是 Flink 或 Spark 等自管理 offset 提交的客户端类型,则状态可能显示为 Empty。PreparingRebalance:准备开启 Rebalance(如消费者加入/退出)。CompletingRebalance:所有成员加入消费组。Stable:消费组内成员可以正常消费。
协议类型 consumer:代表消费者是普通消费者,消费记录保存在服务端,在控制台上正常展示订阅关系。说明:如果消费者使用 Flink 或 Spark 消费,消费模式为 assign,消费记录由客户端自己保存,不会提交到服务端,因此订阅关系不会展示在控制台中。
均衡算法 消费组的分区分配策略:Range:按分区号顺序划分范围,每个消费者分配连续的分区。RoundRobin:将所有分区和消费者按顺序轮询分配,尽可能均匀分布。Sticky:尽量保留原有分配结果,仅在必要时调整(如消费者增减时),减少分区迁移成本。
操作 在订阅关系页面,你可以执行如下操作:offset设置:重置消费组的消费进度,详细介绍请参考重置消费进度。查看消费者详情:查看消费组内所有的消费者的详情信息,详细介绍请参考查看消费组详情。
赞 (0)
上一篇 4天前
下一篇 4天前