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)
