Thank you for the comments. It is a valid scenario that might also lead to race condition. When Kafka replaces the current log with future log, if log cleanup policy is updated from "retention" to "compact" at the same time, there is a small window during which retention and compaction threads might work on the same topic partition. It is a much safer to protect future logs as well.
[ Full content available at: https://github.com/apache/kafka/pull/5591 ] This message was relayed via gitbox.apache.org for [email protected]
