apache-kafka - 无法在kafka中永久保存消息

Question

需要了解如何永远保留在 kafka 上生成的消息。我已经设置了属性log.retention.hours= -1并log.retention.bytes= -1在我的server.properties文件中，但仍然在几天内删除了这些消息。我是否缺少任何其他配置？

任何帮助将不胜感激。谢谢！

标签： apache-kafka

Answer 1

看看 Kafka 的日志压缩：https ://kafka.apache.org/documentation/#compaction

为此，您需要log.cleanup.policy从默认的删除设置为压缩。