CKafka 消费组的生命周期由“自动创建”与“自动清理”两个机制共同定义。通过合理配置,可以实现资源的自动化管理,避免无效消费组占用系统资源。CKafka 支持在控制台提供实例维度的自定义配置功能,支持用户根据业务需求和合规性要求,通过调整位点保留时长,实现空消费组清理周期的自定义配置。
参数说明
参数名称 | 取值范围 | 参数说明 |
自动创建 Consumer group | - | 开启后,客户端使用新的 group id 连接时,系统会自动完成消费组注册。 关闭后,需提前在控制台手动创建消费组,否则客户端将因身份无法识别而报错。 |
Offset 保留时长 | 1 天- 90 天 | 清理逻辑:当消费组状态为 Empty(无活跃成员)且其存储的所有 Offset(位点)均已过期时,系统将判定该消费组生命周期结束,并执行自动清理。 清理时长:由实例的 Offset 保留时长 决定。 |
约束与限制
Offset 保留时长默认为7天,若设置为更短时间(例如5天)可能会立即删除已到期的空消费组。如需缩短或延长空消费组的清理周期,请在集群级属性配置中修改 Offset 保留时长。
清理顺序:系统会先清理过期位点(Offset),只有当消费组内所有位点均被清理且无活跃成员时,才会删除消费组。如果组内还有任何一个位点未过期,消费组将继续保留。
本功能需要内核小版本不低于以下任意版本,专业版实例支持控制台升级内核小版本。
2.4.2_1.2.6
2.8.1_1.1.9
3.2.3_1.0.9
操作步骤
修改自动创建 Consumer group 配置
1. 登录 CKafka 控制台。
2. 在左侧导航栏选择实例列表,选择好地域后单击目标实例的“ID”,进入实例基本信息页面。
3. 在消费组配置模块,单击右上角的配置,根据业务合规要求,开启或关闭 自动创建 Consumer Group 开关。

4. 单击提交,完成修改。
修改 Offset 保留时长
1. 登录 CKafka 控制台。
2. 在左侧导航栏选择实例列表,选择好地域后单击目标实例的“ID”,进入实例基本信息页面。
3. 在集群级属性模块,单击右上角的修改配置,根据业务需求调整 Offset 保留时长。

4. 单击提交,系统提示设置成功后即可完成配置。