Struct HighWatermarkFacts 

pub struct HighWatermarkFacts {
    pub current: i64,
    pub leader_log_end: i64,
    pub isr_size: usize,
    pub effective_min_isr: usize,
}

The partition-wide inputs of Kafka’s Partition.maybeIncrementLeaderHW.

Fields

current: i64

The leader’s high watermark before this step.

leader_log_end: i64

The leader’s log end offset.

isr_size: usize

Kafka’s partitionState.isr.size: the ISR, leader included.

effective_min_isr: usize

Kafka’s Partition.effectiveMinIsr: min.insync.replicas capped by the replica count.

Trait Implementations

impl Clone for HighWatermarkFacts

fn clone(&self) -> HighWatermarkFacts

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for HighWatermarkFacts

impl Debug for HighWatermarkFacts

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

Formats the value using the given formatter.

impl Eq for HighWatermarkFacts

impl PartialEq for HighWatermarkFacts

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for HighWatermarkFacts