apache-kafka - 在 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 开始，此设置还规定了消费者必须完成读取的时间，以确保他们获得最终阶段的有效快照（否则可能会在完成扫描之前收集删除墓碑）。