Struct UnregisterBrokerRecord 

pub struct UnregisterBrokerRecord {
    pub node_id: NodeId,
    pub broker_epoch: i64,
}

KIP-919 / UnregisterBroker (api_key 64), Kafka’s UnregisterBrokerRecord (metadata apiKey 1).

Marks a broker as permanently unregistered: the admin operator confirms that the broker is gone for good and asks the cluster to drop its registration entry from the metadata image. Later Metadata responses no longer advertise the endpoints of the broker, and clients stop routing to it.

As in ClusterControlManager.replay(UnregisterBrokerRecord), the record removes the registration only when broker_epoch is the epoch of the current registration. An apply against an unknown node_id or another epoch does nothing, so a second apply is a no-op.

Fields

node_id: NodeId

broker_epoch: i64

The epoch of the registration this record removes.

Trait Implementations

impl Clone for UnregisterBrokerRecord

fn clone(&self) -> UnregisterBrokerRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for UnregisterBrokerRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for UnregisterBrokerRecord

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for UnregisterBrokerRecord

impl PartialEq for UnregisterBrokerRecord

fn eq(&self, other: &UnregisterBrokerRecord) -> 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 UnregisterBrokerRecord

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 UnregisterBrokerRecord