...
1// ControlledShutdownRequest is an advanced request that can be used to
2// sthudown a broker in a controlled manner.
3//
4// As this is an advanced request and there is little reason to issue it as a
5// client, this request is undocumented. However, the minimal amount of fields
6// here makes the usage rather obvious.
7//
8// Kafka 2.2.0 introduced version 2, proposed in KIP-380.
9//
10// Note that version 0 of this request uses a special encoding format
11// where the request does not include the client ID.
12ControlledShutdownRequest => key 7, max version 3, flexible v3+
13 BrokerID: int32
14 BrokerEpoch: int64(-1) // v2+
15
16// ControlledShutdownResponse is returned from a ControlledShutdownRequest.
17ControlledShutdownResponse =>
18 ErrorCode: int16
19 PartitionsRemaining: [=>]
20 Topic: string
21 Partition: int32
View as plain text