如果在主题上启用了日志压缩,当分区日志中有具有相同键的更新版本时,Kafka 会删除所有旧记录.有关日志压缩的更详细说明,请参阅 - https://medium.com/swlh/introduction-to-topic-log-compaction-in-apache-kafka-3e4d4afd2262I come across the following two phrases from the book "Mastering Kafka Streams and ksqlDB" and author used two terms, what does they really mean "compacted topics" and "uncompacted topics"Does they got anything to with respect to "log compaction" ? 解决方案 Yes, log compaction according to kafka docshttps://kafka.apache.org/documentation/#compactionIf log compaction is enabled on topic, Kafka removes any old records when there is a newer version of it with the same key in the partition log.For more detailed explanation of log compaction refer - https://medium.com/swlh/introduction-to-topic-log-compaction-in-apache-kafka-3e4d4afd2262 这篇关于Kafka - 未压缩的主题与压缩的主题的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持! 上岸,阿里云!
07-23 14:31
查看更多