更新时间:2025-08-21 GMT+08:00
修改Kafka消息老化时间
老化时间即消息的最长保留时间,消费者必须在此时间结束前消费消息,否则消息将被删除。已删除的消息,无法被消费。
Topic老化时间默认为72小时,创建Topic成功之后,您可以根据业务需要修改Topic的老化时间。修改老化时间,不会影响业务。
修改老化时间可以通过以下方式实现:
- 在“实例管理 > Topic管理”中,修改老化时间。
- 在“实例管理 > 配置参数”中,修改“log.retention.hours”参数值,具体步骤请参考修改Kafka实例配置参数。
如果Topic已设置老化时间,则“实例管理 > 配置参数”中的log.retention.hours值对此Topic不生效。仅当Topic未设置老化时间时,该参数值才会生效。例如:Topic01设置的老化时间为60小时,log.retention.hours值为72小时,Topic01实际的老化时间仍为60小时。
约束与限制
- 单机实例只支持在“实例管理 > Topic管理”中,修改老化时间。
- 批量修改老化时间时,每次最多修改50个Topic的老化时间。
修改Kafka消息老化时间
Kafka控制台支持修改单个Topic的消息老化时间,也支持批量修改Topic的消息老化时间。
- 登录Kafka控制台。
- 在管理控制台左上角单击
,选择Kafka实例所在的区域。
- 单击Kafka实例的名称,进入实例详情页面。
- 在左侧导航栏选择“实例管理 > Topic管理”,进入Topic列表页面。
- 通过以下任意一种方法,修改Topic老化时间。
- 勾选Topic名称左侧的方框,可选一个或多个,单击信息栏左上侧的“编辑Topic”。
- 在待修改老化时间的Topic所在行,单击“编辑”。
- 在“编辑Topic”对话框中,输入老化时间(取值范围:1~720),单击“确定”。
设置成功后,在Topic列表页面,查看修改后的老化时间。
- 登录Kafka控制台。
- 在管理控制台左上角单击
,选择Kafka实例所在的区域。
- 单击Kafka实例的名称,进入实例详情页面。
- 在左侧导航栏选择“实例管理 > Topic管理”,进入Topic列表页面。
- 勾选待修改老化时间的Topic,单击信息栏左上侧的“批量编辑Topic”,弹出“批量编辑Topic”对话框。
- 在“批量操作”区域,勾选“老化时间(小时)”,并输入老化时间(取值范围:1~720)。在“批量数据预览”区域,查看修改前和修改后的老化时间。确认无误后,单击“确定”。
图1 批量修改老化时间
设置成功后,在Topic列表页面,查看修改后的老化时间。
相关文档
- 如果您希望通过API修改消息老化时间,请参考修改Kafka实例Topic。
- 消息超过老化时间,消息仍存在的原因