tencent cloud

消息队列 CKafka 版

动态与公告
新功能发布记录
Broker 版本升级记录
公告
产品简介
TDMQ 产品系列介绍与选型
什么是消息队列 CKafka 版
产品优势
应用场景
技术架构
产品系列介绍
开源 Kafka 版本支持说明
与开源 Kafka 对比
高可用
使用限制
地域和可用区
相关云服务
产品计费
计费概述
价格说明
计费示例
按小时付费转包年包月
续费说明
查看消费明细
欠费说明
退费说明
快速入门
入门流程指引
准备工作
VPC 网络接入
公网域名接入
用户指南
使用流程指引
配置账号权限
创建实例
配置 Topic
连接实例
管理消息
管理消费组
管理实例
变更实例规格
配置限流
配置弹性伸缩策略
配置高级特性
查看监控和配置告警
使用连接器同步数据
实践教程
集群资源评估
客户端实践教程
日志接入
开源生态对接
替换支撑路由(旧)
迁移指南
迁移方案概述
使用开源工具迁移集群
故障处理
Topic 相关
客户端相关
消息相关
API 参考
History
Introduction
API Category
Making API Requests
Other APIs
ACL APIs
Instance APIs
Routing APIs
DataHub APIs
Topic APIs
Data Types
Error Codes
SDK 参考
SDK 概述
Java SDK
Python SDK
Go SDK
PHP SDK
C++ SDK
Node.js SDK
连接器相关 SDK
安全与合规
权限管理
网络安全
删除保护
事件记录
云 API 审计
常见问题
实例相关
Topic 相关
Consumer Group 相关
客户端相关
网络问题
监控相关
消息相关
服务协议
服务等级协议
联系我们
词汇表

查看 Topic 订阅关系

PDF
聚焦模式
字号
最后更新时间: 2026-01-20 15:49:29
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 设置:重置消费组的消费进度,详细介绍请参考查看和手动重置消费进度
查看消费组详情:查看消费组内所有的消费者的详情信息,详细介绍请参考查看消费组详情


帮助和支持

本页内容是否解决了您的问题?

填写满意度调查问卷,共创更好文档体验。

文档反馈