Kafka不会删除主题中的旧消息

在 kafka 中，我将保留策略设置为 3 天server.properties

############################# Log Retention Policy #############################
...
log.retention.hours=72
...

话题有retention.ms set to 172800000 (48h).

但是，文件夹 /tmp/kafka-logs 中仍然有旧数据，并且没有被删除。更改这些属性后我等了几个小时。

有什么需要设置的吗？所有主题都是从当前开始生成和使用的。

编辑：看来cleanup.policy应默认为delete根据卡夫卡文档。

retention.ms or retention.bytes指定删除数据的方式。

关键是要设置log.cleanup.policy to compact or delete。我没有设置这个。

跑步：kafka-topics --zookeeper 127.0.0.1:2181 --topic topic1 --describe显示主题上设置的属性，例如。Configs:retention.ms=172800000,cleanup.policy=compact

The cleanup.policy必须设置。我也是手动设置的retention.ms / retention.bytes控制清理触发器。