Configuration parameters for the log cleaner
An on-disk message set.
An append-only log for storing messages.
The cleaner is responsible for removing obsolete records from logs which have the dedupe retention strategy.
Configuration settings for a log
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