在 0.8.1 版本的 kafka 中创建主题时的 delete.retention.ms

Question

我在 0.8.1 版本的 kafka 中创建主题时配置了这个属性 delete.retention.ms。这个属性有什么作用？是否会在 kafka 的特定时间间隔后删除消息。

Answer 1

不，delete.retention.ms或者log.cleaner.delete.retention.ms是日志压缩中使用的属性，默认情况下关闭。 log.rentention.hours是您可以控制何时删除消息的属性。

来自Kafka 0.8.1 文档的Broker Configs

日志保留时间

在删除之前保留日志段的时间量，即所有主题的默认数据保留窗口。请注意，如果 log.retention.minutes 和 log.retention.bytes 都设置了，我们会在超过任一限制时删除一个段。

log.cleaner.delete.retention.ms

为日志压缩主题保留删除墓碑标记的时间量。如果消费者从偏移量 0 开始，则此设置还给出了消费者必须完成读取的时间限制，以确保他们获得最后阶段的有效快照（否则可能会在完成扫描之前收集删除逻辑删除）。