Module isr 

Classic Kafka ISR decisions: AlterPartition validation on the controller, ISR maintenance and follower catch-up tracking on the partition leader, and the high-watermark computation.

Structs

AlterPartitionFacts

What the controller knows about one AlterPartition partition row, as Kafka’s ReplicationControlManager.validateAlterPartitionData reads it.

HighWatermarkFacts

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

HwmReplica

One remote replica as Kafka’s Partition.maybeIncrementLeaderHW weighs it.

IsrCandidateFacts

What the leader knows about one candidate at an ISR maintenance scan, read once at the scan’s single timestamp.

IsrEligibilityFacts

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).

IsrMemberFacts

The inputs of isr_maintenance_selected, superseded by IsrCandidateFacts. Every time bound is replica.lag.time.max.ms, measured from the scan’s single timestamp.

Enums

CaughtUpCredit

Which fetch time, if any, a follower fetch proves the follower was caught up at.

IsrAdmission

The first AlterPartition validation failure of one partition row, or Admit.

IsrMemberRole

Where one candidate stands in the partition the leader maintains.

ProposedIsr

How a proposed ISR relates to the partition’s assignment and leader.

Functions

follower_caught_up_credit

Kafka’s Replica.updateFetchStateOrThrow choice of lastCaughtUpTimeMs.

isr_admission

Apply Kafka’s ordered AlterPartition checks to one partition row.

isr_candidate_selected

Decide whether one candidate belongs in the next ISR proposal.

isr_maintenance_selected

krabka’s former ISR scan rule, superseded by crate::isr::isr_candidate_selected.

isr_proposal_changed

Report a proposal only when at least one unique member is added or removed.

leader_high_watermark

Compute the leader’s next high watermark.

replica_isr_eligible

Decide whether one replica may join the ISR, Kafka’s Partition.isReplicaIsrEligible.