1// For KIP-500 / KIP-631, BrokerHeartbeatRequest is an internal
2// broker-to-broker only request.
3BrokerHeartbeatRequest => key 63, max version 0, flexible v0+
4 // The broker ID.
5 BrokerID: int32
6 // The broker's epoch.
7 BrokerEpoch: int64(-1)
8 // The highest metadata offset that the broker has reached.
9 CurrentMetadataOffset: int64
10 // True if the broker wants to be fenced.
11 WantFence: bool
12 // True if the broker wants to be shutdown.
13 WantShutdown: bool
14
15// BrokerHeartbeatResponse is a response to a BrokerHeartbeatRequest.
16BrokerHeartbeatResponse =>
17 ThrottleMillis
18 // Any error code, or 0.
19 ErrorCode: int16
20 // True if the broker has approximately caught up with the latest metadata.
21 IsCaughtUp: bool
22 // True if the broker is fenced.
23 IsFenced: bool(true)
24 // True if the broker should proceed with its shutdown.
25 ShouldShutdown: bool
View as plain text