Description
The following api is supposed to block until cleaning is done up to offset. However, this is not enforced.
def awaitCleaned(topic: String, part: Int, offset: Long, timeout: Long = 30000L)
Attachments
Issue Links
- is duplicated by
-
KAFKA-2669 Fix LogCleanerIntegrationTest
-
- Resolved
-