Struct IsrEligibilityFacts 

pub struct IsrEligibilityFacts {
    pub fenced: bool,
    pub shutting_down: bool,
    pub fetch_broker_epoch: Option<i64>,
    pub alive_broker_epoch: Option<i64>,
}

What the leader’s metadata cache and the follower’s last Fetch say about whether one replica may join the ISR, the inputs of Kafka’s Partition.isReplicaIsrEligible (KIP-841).

Fields

fenced: bool

Kafka’s metadataCache.isBrokerFenced.

shutting_down: bool

Kafka’s metadataCache.isBrokerShuttingDown.

fetch_broker_epoch: Option<i64>

Kafka’s ReplicaState.brokerEpoch: the broker epoch the follower’s last Fetch to this leader carried, -1 when that Fetch carried none, and None before this leader received one.

alive_broker_epoch: Option<i64>

Kafka’s metadataCache.getAliveBrokerEpoch: the broker’s registered epoch while it is registered and unfenced, None otherwise.

Trait Implementations

impl Clone for IsrEligibilityFacts

fn clone(&self) -> IsrEligibilityFacts

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for IsrEligibilityFacts

impl Debug for IsrEligibilityFacts

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

Formats the value using the given formatter.

impl Eq for IsrEligibilityFacts

impl PartialEq for IsrEligibilityFacts

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for IsrEligibilityFacts