1// For KIP-500 / KIP-631, BrokerRegistrationRequest is an internal
2// broker-to-broker only request.
3BrokerRegistrationRequest => key 62, max version 1, flexible v0+
4 // The broker ID.
5 BrokerID: int32
6 // The cluster ID of the broker process.
7 ClusterID: string
8 // The incarnation ID of the broker process.
9 IncarnationID: uuid
10 // The listeners for this broker.
11 Listeners: [=>]
12 // The name of this endpoint.
13 Name: string
14 // The hostname.
15 Host: string
16 // The port.
17 Port: uint16
18 // The security protocol.
19 SecurityProtocol: int16
20 // Features on this broker.
21 Features: [=>]
22 // The name of the feature.
23 Name: string
24 // The minimum supported feature level.
25 MinSupportedVersion: int16
26 // The maximum supported feature level.
27 MaxSupportedVersion: int16
28 // The rack that this broker is in, if any.
29 Rack: nullable-string
30 // If the required configurations for ZK migration are present, this value is
31 // set to true.
32 IsMigratingZkBroker: bool // v1+
33
34// BrokerRegistrationResponse is a response to a BrokerRegistrationRequest.
35BrokerRegistrationResponse =>
36 ThrottleMillis
37 // Any error code, or 0.
38 ErrorCode: int16
39 // The broker's assigned epoch, or -1 if none was assigned.
40 BrokerEpoch: int64(-1)
View as plain text