Struct ProducerSnapshotEntryFacts 

pub struct ProducerSnapshotEntryFacts {
    pub producer_id: i64,
    pub producer_epoch: i16,
    pub last_sequence: i32,
    pub last_offset: i64,
    pub offset_delta: i32,
    pub coordinator_epoch: i32,
    pub current_txn_first_offset: i64,
}

One decoded producer-state snapshot entry, field for field as Kafka’s ProducerStateManager snapshot schema (version 1) lays it out, minus the timestamp, which no validity rule reads.

Seven integers of four widths with seven meanings travel as one struct, so a transposed call site does not compile.

Fields

producer_id: i64

ProducerId.

producer_epoch: i16

ProducerEpoch.

last_sequence: i32

LastSequence, or -1 for a producer whose only record is a marker.

last_offset: i64

LastOffset, or -1 with the same meaning.

offset_delta: i32

OffsetDelta: the last batch’s offset count less one.

coordinator_epoch: i32

CoordinatorEpoch, or -1 before any marker.

current_txn_first_offset: i64

CurrentTxnFirstOffset, or -1 with no open transaction.

Trait Implementations

impl Clone for ProducerSnapshotEntryFacts

fn clone(&self) -> ProducerSnapshotEntryFacts

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for ProducerSnapshotEntryFacts

impl Debug for ProducerSnapshotEntryFacts

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

Formats the value using the given formatter.

impl Eq for ProducerSnapshotEntryFacts

impl PartialEq for ProducerSnapshotEntryFacts

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ProducerSnapshotEntryFacts