更新时间: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的消息老化时间。

  1. 登录Kafka控制台
  2. 在管理控制台左上角单击,选择Kafka实例所在的区域。
  3. 单击Kafka实例的名称,进入实例详情页面。
  4. 在左侧导航栏选择“实例管理 > Topic管理”,进入Topic列表页面。
  5. 通过以下任意一种方法,修改Topic老化时间。

    • 勾选Topic名称左侧的方框,可选一个或多个,单击信息栏左上侧的“编辑Topic”。
    • 在待修改老化时间的Topic所在行,单击“编辑”。

  6. 在“编辑Topic”对话框中,输入老化时间(取值范围:1~720),单击“确定”。

    设置成功后,在Topic列表页面,查看修改后的老化时间。

  1. 登录Kafka控制台
  2. 在管理控制台左上角单击,选择Kafka实例所在的区域。
  3. 单击Kafka实例的名称,进入实例详情页面。
  4. 在左侧导航栏选择“实例管理 > Topic管理”,进入Topic列表页面。
  5. 勾选待修改老化时间的Topic,单击信息栏左上侧的“批量编辑Topic”,弹出“批量编辑Topic”对话框。
  6. 在“批量操作”区域,勾选“老化时间(小时)”,并输入老化时间(取值范围:1~720)。在“批量数据预览”区域,查看修改前和修改后的老化时间。确认无误后,单击“确定”。

    图1 批量修改老化时间

    设置成功后,在Topic列表页面,查看修改后的老化时间。

相关文档