CleanerThread takes the following to be created:
- Thread ID
CleanerThread is created when:
LogCleaneris requested to start up
CleanerThread uses the following as the thread name (with the threadId)
doWork is part of the
In case of
tryCleanFilthiestLog prints out the following WARN message to the logs:
Unexpected exception thrown when cleaning log [log]. Marking its partition ([topicPartition]) as uncleanable
Cleaning Filthiest Log¶
cleaned flag to indicate whether a log to clean was found or not.
If there is no log to clean up,
cleaned flag). Otherwise,
cleanFilthiestLog cleanLog and "returns"
CleanerThread uses kafka.log.LogCleaner logger.