更新时间:2024-12-12 GMT+08:00
分享

修改Kafka消息老化时间

老化时间即消息的最长保留时间,消费者必须在此时间结束前消费消息,否则消息将被删除。已删除的消息,无法被消费。

Topic老化时间默认为72小时,创建Topic成功之后,您可以根据业务需要修改Topic的老化时间。修改老化时间,不会影响业务。

修改老化时间可以通过以下方式实现:

  • 在“Topic管理”中,修改老化时间。
  • 在“配置参数”中,修改“log.retention.hours”参数值,具体步骤请参考修改Kafka实例配置参数

如果Topic已经设置了老化时间,此时“配置参数”中的log.retention.hours值将不对此Topic生效。仅在Topic中未设置老化时间时,“配置参数”中的log.retention.hours值才会对此Topic生效。例如:Topic01设置的老化时间为60小时,“配置参数”中的log.retention.hours值为72小时,此时Topic01实际的老化时间为60小时。

修改Kafka消息老化时间

  1. 登录管理控制台。
  2. 在管理控制台左上角单击,选择区域。

    请选择Kafka实例所在的区域。

  3. 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务Kafka版”,进入分布式消息服务Kafka专享版页面。
  4. 在左侧导航栏单击“Kafka实例”,进入Kafka实例列表页面。
  5. 单击Kafka实例的名称,进入实例详情页面。
  6. 在左侧导航栏选择“Topic管理”,进入Topic列表页面。
  7. 通过以下任意一种方法,修改Topic老化时间。

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

  8. 在“编辑Topic”对话框中,输入老化时间,单击“确定”。

相关文档