Kafka参数cleanup.policy与log.cleanup.policy的区别是什么？

Kafka两个清理策略参数差异 #

• log.cleanup.policy：属于Broker全局配置，定义在Broker节点的server.properties配置文件中，是所有未单独配置清理策略的主题的默认生效规则，集群默认值为delete。
• cleanup.policy：属于单主题级配置，优先级高于全局配置。创建或修改主题时指定该参数后，对应主题的清理策略就会以该配置为准，不会受全局log.cleanup.policy的影响。

两个参数的可选取值完全一致，支持三类配置：

• delete：按日志保留时间、保留大小规则淘汰旧消息，是默认策略
• compact：按键压缩策略，相同key的消息仅保留最新版本，适用于消息去重、状态存储等场景
• delete,compact：两种策略同时生效，会同时触发日志淘汰和键压缩规则

内容的提问来源于stack exchange，提问作者Ryan Lyu