创建消费组

最近更新时间:2025-08-28 17:40:12

我的收藏

操作场景

Consumer Group(消费组)是 Kafka 提供的可扩展且具有容错性的消费者机制,一个消费组中存在多个消费者,组内的所有消费者共同消费订阅 Topic 中的消息。一个消费者可同时消费多个 Partition,但一个 Partition 只能被消费组内的一个消费者消费。

约束与限制

单个实例下所有自动和手动创建的消费组数量总和建议不超过 500 个,超出会有一定限制。

操作步骤

通过控制台手动创建消费组
通过客户端自动创建消费组
1. 登录 CKafka 控制台
2. 在左侧导航栏选择实例列表,选择好地域后单击目标实例的“ID”,进入实例基本信息页面。
3. 在实例基本信息页面,选择 Consumer Group 页签,单击新建消费组,设置消费组信息。
消费组名称:自定义名称,需要符合命名规则,只能包含字母、数字、下划线、"-"".",且必须以字母开头。
选择 Topic:在下拉框中选择消费组要订阅的 Topic,支持同时勾选多个 Topic。

4. 单击提交,在 Consumer Group 列表可以看到刚刚创建的消费者组。
说明:
对于控制台创建的消费组,其 offset 将从最新开始,即消费组只消费创建消费组之后的新消息。如有消费历史消息需求可以在未使用该消费组前通过控制台重置消费位点,详细介绍请参考重置消费进度
自动创建消费组表示一个新的消费者组首次订阅 Topic 时,客户端会自动检测该消费组是否存在,若不存在,且消费组名称符合命名规则(只能包含字母、数字、下划线、"-"".",必须以字母开头),系统会自动创建此消费组。
CKafka 默认为您开启了自动创建 Consumer Group 的开关,您可以在 CKafka 控制台手动开启或者关闭,关闭后只能使用在控制台上已有的消费组,无法自动新建消费组。
仅支持专业版实例且实例版本在 2.4.1 及以上支持在控制台手动关闭自动创建 Consumer Group 的开关。

开启/关闭自动创建 Consumer Group

1. 登录 CKafka 控制台
2. 在左侧导航栏选择实例列表,选择好地域后单击目标实例的“ID”,进入实例基本信息页面。
3. 消费组配置模块,单击右上角的配置,可以手动开启或者关闭自动创建 Consumer Group 开关。