LogCleanerManager takes the following to be created:
- Log directories
TopicPartitions and their UnifiedLogs (
LogCleanerManager is created along with a LogCleaner.
LogCleanerManager is a KafkaMetricsGroup and registers the following performance metrics in kafka.log:type=LogCleanerManager group.
|uncleanable-bytes||(for every log directory)|
|uncleanable-partitions-count||(for every log directory)|
grabFilthiestCompactedLog( time: Time, preCleanStats: PreCleanStats = new PreCleanStats()): Option[LogToClean]
grabFilthiestCompactedLog is used when:
CleanerThreadis requested to clean the filthiest log
isCompactAndDelete( log: UnifiedLog): Boolean
LogCleanerManager uses kafka.log.LogCleaner logger.