修改topic级别Kafka retention time配置后是否需要重启Kafka服务？

核心结论 #

修改Topic级别的retention time（消息保留时间）配置无需重启Kafka集群，配置提交后会自动生效。

生效规则与操作说明 #

• 常规修改Topic级别配置的官方命令为kafka-configs.sh，参考示例如下（设置保留时间为1天）：

  bin/kafka-configs.sh --zookeeper 你的zk连接地址 --alter --entity-type topics --entity-name 你的Topic名称 --add-config retention.ms=86400000
  

• 配置提交后会直接写入ZooKeeper，集群内所有Broker节点会实时感知到配置变更，不需要重启任何服务。
• 注意配置不会立刻清理存量过期数据：Kafka的日志清理线程默认每5分钟扫描一次（对应Broker端参数log.retention.check.interval.ms），下一次扫描到该Topic的日志分段时，就会按照新的保留规则清理过期数据。

验证与注意事项 #

• Topic级别配置优先级高于Broker全局的保留时间配置，修改完成后会自动覆盖全局规则，不需要调整Broker端的默认配置。
• 可以通过以下命令验证配置是否写入成功，只要返回结果中存在你设置的retention.ms参数值，就代表配置已经生效，等待清理线程执行即可：

  bin/kafka-configs.sh --zookeeper 你的zk连接地址 --describe --entity-type topics --entity-name 你的Topic名称
  

• 不建议直接手动修改ZooKeeper内的节点配置，优先使用官方工具或AdminClient API操作，避免出现配置格式错误。

内容的提问来源于stack exchange，提问作者Ravi Teja RVN