This is to address issue described in KAFKA-7322. To fix race condition between log retention and log cleaner when dynamically switching topic cleanup policy, existing log cleaner inprogress map is used to prevent more than one thread working on the same topic partition.
[ Full content available at: https://github.com/apache/kafka/pull/5591 ] This message was relayed via gitbox.apache.org for [email protected]
