Jun Rao created KAFKA-1544: ------------------------------ Summary: LogCleaner may take a long time to shutdown Key: KAFKA-1544 URL: https://issues.apache.org/jira/browse/KAFKA-1544 Project: Kafka Issue Type: Bug Components: core Affects Versions: 0.8.2 Reporter: Jun Rao
We have the following code in LogCleaner. Since the cleaner thread is shutdown w/o interrupt. If may take up to backoff time for the cleaner thread to detect the shutdown flag. private def cleanOrSleep() { cleanerManager.grabFilthiestLog() match { case None => // there are no cleanable logs, sleep a while time.sleep(config.backOffMs) -- This message was sent by Atlassian JIRA (v6.2#6252)