Struct CompactionContext 

pub struct CompactionContext {
    pub now: SystemTime,
    pub last_stable_offset: Offset,
}

Inputs to one Log::compact pass that depend on broker-side state.

These inputs are the wall clock that computes the KIP-534 delete horizons, and the last stable offset that bounds what a pass may rewrite. The pass reads the active producers from the producer state of the log itself, as Kafka’s Cleaner.cleanSegments does.

Fields

now: SystemTime

Wall clock for this pass. It drives delete-horizon stamps and expiry.

last_stable_offset: Offset

The replica’s last stable offset: the first offset that still belongs to an open transaction, or that a complete transaction’s marker has not yet reached the high watermark for.

A pass consumes only sealed segments that end at or below it, which is the bound Kafka’s LogCleanerManager.cleanableOffsets takes: the minimum of log.lastStableOffset(), the active segment’s base offset and the segment the minimum compaction lag allows. The high watermark alone is not enough, because the records between the LSO and the high watermark belong to transactions with no marker yet; rewriting them early would leave the output segment’s aborted-transaction index unable to learn about a marker that arrives later, and a read_committed consumer could then see a record from a transaction that later aborts.

Trait Implementations

impl Clone for CompactionContext

fn clone(&self) -> CompactionContext

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CompactionContext

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.