Luke Chen created KAFKA-14556: --------------------------------- Summary: log cleaner throttler start time is correct Key: KAFKA-14556 URL: https://issues.apache.org/jira/browse/KAFKA-14556 Project: Kafka Issue Type: Bug Reporter: Luke Chen
Log cleaner throttler will do throttling check very 300ms. The expected throttling work is like this: disk IO operation for 300ms -> check if throttling is needed (sleep to slow down the IO) -> continue the disk IO operation -> check ... But the 300ms interval start time is started when log cleaner created [here|https://github.com/jolshan/kafka/blob/trunk/core/src/main/scala/kafka/utils/Throttler.scala#L49]. So, even if there's no logs needed to be cleaned, the interval time still elapses. When logs appeared and ready to be cleaned, the 300ms interval will exceed immediately and start to verify if throttling is needed, which is unexpected. -- This message was sent by Atlassian Jira (v8.20.10#820010)