Skip to main content

Module quorum_state

Module quorum_state 

Source
Expand description

KRaft quorum-state persistence admission.

Enums§

QuorumStateLoadDecision
How a parsed quorum-state record may restore the durable vote.
QuorumStateWriteDecision
Whether an in-memory quorum state can be represented exactly by Kafka’s signed, versioned JSON fields.

Functions§

quorum_state_load_decision
Admit only schema v0 or v1 records with a nonnegative term, the exact vote sentinel, and valid version-specific fields.
quorum_state_write_decision
Reject states that would be clamped, lose an identity, or select an unsupported schema when persisted. The one ensures pins both variants: Accept exactly when fits_signed_json holds.