kafka-log-LogCleanerManager.adoc

LogCleanerManager

LogCleanerManager uses cleaner-offset-checkpoint for the name of the offset checkpoint files for every log directory (in checkpoints registry).

Table 1. LogCleanerManager’s Internal Properties (e.g. Registries, Counters and Flags)

Name	Description
checkpoints	OffsetCheckpointFiles per log directory Used in updateCheckpoints, maybeTruncateCheckpoint, and alterCheckpointDir to look up the OffsetCheckpointFile per log data directory Used in allCleanerCheckpoints to access all OffsetCheckpointFiles Used in handleLogDirFailure to exclude a failed log directory from cleaning