Struct BrokerRegistrationRecord 

pub struct BrokerRegistrationRecord {
    pub node_id: NodeId,
    pub broker_epoch: i64,
    pub incarnation_id: Uuid,
    pub host: String,
    pub port: u16,
    pub rack: Option<String>,
    pub endpoints: Vec<BrokerEndpoint>,
    pub log_dirs: Vec<Uuid>,
    pub fenced: bool,
    pub in_controlled_shutdown: bool,
    pub cordoned_log_dirs: Option<Vec<Uuid>>,
    pub features: BTreeMap<String, (i16, i16)>,
}

Fields

node_id: NodeId

broker_epoch: i64

KIP-903 broker epoch: the raft log offset at which this registration record committed. The controller leader assigns it at append time in on_submit_change. A freshly-built literal carries 0 until the leader stamps it. AlterPartition uses it to fence stale replicas from the ISR.

incarnation_id: Uuid

KIP-631: UUID that identifies this specific process invocation of the broker. Generated once at first boot and persisted in {log_dir}/incarnation_id. A JVM controller uses it to detect broker restarts and fence stale replica memberships.

host: String

Legacy single-listener host, used as inter-broker default and by pre-v9 Metadata responses. v9+ projects Self::endpoints.

port: u16

rack: Option<String>

endpoints: Vec<BrokerEndpoint>

Per-listener endpoints. Empty on records written before this field was added; populated from BrokerConfig::effective_listeners() for self-registration.

log_dirs: Vec<Uuid>

KIP-858 stable IDs for the broker’s online log directories. Empty at metadata versions before 3.7-IV2 and in legacy snapshots.

fenced: bool

KIP-631 fencing state. Kafka writes a new registration fenced (the RegisterBrokerRecord schema default) and unfences it with a BrokerRegistrationChangeRecord once the broker catches up.

in_controlled_shutdown: bool

KIP-841: the broker is in controlled shutdown. Only a BrokerRegistrationChangeRecord sets it; only a new registration clears it.

cordoned_log_dirs: Option<Vec<Uuid>>

KIP-1066 cordoned log directories. None until the broker first reports them in a heartbeat, as in Kafka’s BrokerRegistration. Only carried from metadata.version 4.3-IV0.

features: BTreeMap<String, (i16, i16)>

KIP-584 feature ranges advertised by this broker at registration. Empty only for legacy Krabka snapshots written before the ranges were retained in the image.

Trait Implementations

impl Clone for BrokerRegistrationRecord

fn clone(&self) -> BrokerRegistrationRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BrokerRegistrationRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for BrokerRegistrationRecord

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for BrokerRegistrationRecord

impl PartialEq for BrokerRegistrationRecord

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for BrokerRegistrationRecord

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 BrokerRegistrationRecord