Skip to main content

broker_heartbeat_decision

krabka_verified::registration

Function broker_heartbeat_decision 

Source 
pub fn broker_heartbeat_decision(
    registered_epoch: Option<i64>,
    request_epoch: i64,
    metadata_offset: i64,
) -> BrokerHeartbeatDecision
Expand description

Fence an absent or stale registration, as Kafka’s ClusterControlManager.checkBrokerEpoch does, and otherwise report whether the broker has replayed its own registration record.