Jun Rao created KAFKA-1201:
------------------------------
Summary: 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
Assignee: Jay Kreps
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.1.5#6160)
