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

Topic 的订阅关系展示了当前所有消费者组的订阅状态，包括消费组列表、在线状态及分区分配情况。通过查看这些信息，您可以确认消息是否被正常消费、及时发现无消费者订阅的异常 Topic，并评估业务变更的影响范围。本文介绍通过 CKafka 控制台查看 Topic 订阅关系操作步骤。
操作步骤
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 设置：重置消费组的消费进度，详细介绍请参考重置消费进度。
查看消费组详情：查看消费组内所有的消费者的详情信息，详细介绍请参考查看消费组详情。
﻿

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

查看 Topic 订阅关系

本页目录：

操作步骤