[ https://issues.apache.org/jira/browse/KAFKA-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Manikumar Reddy resolved KAFKA-1201. ------------------------------------ Resolution: Duplicate Assignee: (was: Jay Kreps) Fix Version/s: 0.9.0.0 This was fixed in KAFKA-2669 > offset in LogCleaner.awaitCleaned is not enforced > ------------------------------------------------- > > Key: KAFKA-1201 > URL: https://issues.apache.org/jira/browse/KAFKA-1201 > Project: Kafka > Issue Type: Bug > Components: core > Affects Versions: 0.8.1 > Reporter: Jun Rao > Fix For: 0.9.0.0 > > > 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) -- This message was sent by Atlassian JIRA (v6.3.4#6332)