1// Part of KIP-595 to replace Kafka's dependence on Zookeeper with a
2// Kafka-only raft protocol,
3// EndQuorumEpochRequest is sent by a leader to gracefully step down as leader
4// (i.e. on shutdown). Stepping down begins a new election.
5//
6// Since this is relatively Kafka internal, most fields are left undocumented.
7EndQuorumEpochRequest => key 54, max version 0, admin
8 ClusterID: nullable-string
9 Topics: [=>]
10 Topic: string
11 Partitions: [=>]
12 Partition: int32
13 // The current leader ID that is resigning.
14 LeaderID: int32
15 // The current epoch.
16 LeaderEpoch: int32
17 // A sorted list of preferred successors to start the election.
18 PreferredSuccessors: [int32]
19
20EndQuorumEpochResponse =>
21 ErrorCode: int16
22 Topics: [=>]
23 Topic: string
24 Partitions: [=>]
25 Partition: int32
26 ErrorCode: int16
27 // The ID of the current leader, or -1 if the leader is unknown.
28 LeaderID: int32
29 // The latest known leader epoch.
30 LeaderEpoch: int32
View as plain text