Struct PartitionRecord 

pub struct PartitionRecord {
    pub topic: String,
    pub partition: i32,
    pub leader: NodeId,
    pub replicas: Vec<NodeId>,
    pub isr: Vec<NodeId>,
    pub leader_epoch: LeaderEpoch,
    pub adding_replicas: Vec<NodeId>,
    pub removing_replicas: Vec<NodeId>,
    pub directories: Vec<Uuid>,
    pub partition_epoch: i32,
}

Fields

topic: String

partition: i32

leader: NodeId

replicas: Vec<NodeId>

isr: Vec<NodeId>

leader_epoch: LeaderEpoch

Per-partition leader epoch (KIP-320). Bumped on every leader change. Older on-disk metadata is not migrated. #[serde(transparent)] on LeaderEpoch keeps the on-disk bincode bytes identical to a bare i32.

adding_replicas: Vec<NodeId>

Replicas being added in an in-flight reassignment. Empty when no reassignment in flight. KIP-455.

removing_replicas: Vec<NodeId>

Replicas being removed in an in-flight reassignment. Empty when no reassignment in flight. KIP-455.

directories: Vec<Uuid>

KIP-858: the log-directory UUID that hosts each replica, parallel to Self::replicas in the same index order. The reserved ids are Kafka’s DirectoryId sentinels (see crate::directory_id): MIGRATING, the nil UUID, is a replica placed before 3.7-IV2 or on a broker with no log-dir ids, and UNASSIGNED is a replica the controller placed on a multi-dir broker that has not yet reported its AssignReplicasToDirs. An empty list reads as every replica MIGRATING, as Kafka’s PartitionRegistration reads it. The controller matches this against the replica slot of a broker to map the failed-dir UUID of that broker to the partitions it must fail over.

partition_epoch: i32

KIP-631: per-partition state epoch. It increments on every state change, such as a leader election, an ISR change, or a reassignment. It is 0 on creation. The default of -1 matches the KIP-631 schema default, for compatibility with records written before this field existed.

Trait Implementations

impl Clone for PartitionRecord

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PartitionRecord

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

Formats the value using the given formatter.

impl Default for PartitionRecord

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for PartitionRecord

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for PartitionRecord

impl PartialEq for PartitionRecord

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for PartitionRecord

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for PartitionRecord