Enum OffsetSpec 

pub enum OffsetSpec {
    Earliest,
    Latest,
    Timestamp(i64),
    MaxTimestamp,
    EarliestLocal,
    LatestTiered,
}

Offset specification for AdminClient::list_offsets.

Variants

Earliest

The earliest available offset in the partition (log start).

Latest

The end offset (high-watermark) of the partition.

Timestamp(i64)

The first offset whose timestamp is ≥ the given milliseconds since the Unix epoch.

MaxTimestamp

The offset of the record carrying the largest timestamp in the partition (KIP-734, ListOffsets v7+).

Not the same as Latest when producers write out of order — which they do whenever CreateTime timestamps come from application clocks, or when a partition is fed by several producers. This is the spec that answers “when was this partition last genuinely written to”, which Latest cannot.

EarliestLocal

The earliest offset still held in the broker’s local storage (KIP-405 tiered storage, ListOffsets v8+).

Everything between Earliest and this offset lives in remote storage, where reads are typically orders of magnitude slower. A consumer or backfill job about to scan from the log start can use the gap to decide whether it is about to pull from object storage.

LatestTiered

The last offset that has been copied to remote storage (KIP-1005, ListOffsets v9+).

The tiering frontier: everything at or below it survives local retention.

Trait Implementations

impl Clone for OffsetSpec

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for OffsetSpec

impl Debug for OffsetSpec

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

Formats the value using the given formatter.

impl Eq for OffsetSpec

impl PartialEq for OffsetSpec

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for OffsetSpec