Configuration parameters for the log cleaner
An on-disk message set.
An append-only log for storing messages.
Struct to hold various quantities we compute about each message set before appending to the log
The cleaner is responsible for removing obsolete records from logs which have the dedupe retention strategy.
The entry point to the kafka log management subsystem.
A segment of the log.
An index that maps offsets to physical file locations for a particular log segment.
The mapping between a logical log offset and the physical position in some log file of the beginning of the message set entry with the given offset.
An hash table used for deduplicating the log.
Helper functions for logs