我正在使用 kafka_2.10-0.10.0.1。我创建了 1 个分区的主题。我知道默认的清理策略是“删除”。我想一直保留主题中的所有记录(不删除任何记录)。什么是正确的方法:使“log.cleaner.enable=false”或“log.cleanup.policy=compact”?谢谢你
apache-kafka
apache-kafka ×1