1// Part of KIP-595 to replace Kafka's dependence on Zookeeper with a
2// Kafka-only raft protocol,
3// BeginQuorumEpochRequest is sent by a leader (once it has enough votes)
4// to all voters in the election.
5//
6// Since this is relatively Kafka internal, most fields are left undocumented.
7BeginQuorumEpochRequest => key 53, max version 0, admin
8 ClusterID: nullable-string
9 Topics: [=>]
10 Topic: string
11 Partitions: [=>]
12 Partition: int32
13 // The ID of the newly elected leader.
14 LeaderID: int32
15 // The epoch of the newly elected leader.
16 LeaderEpoch: int32
17
18BeginQuorumEpochResponse =>
19 ErrorCode: int16
20 Topics: [=>]
21 Topic: string
22 Partitions: [=>]
23 Partition: int32
24 ErrorCode: int16
25 // The ID of the current leader, or -1 if the leader is unknown.
26 LeaderID: int32
27 // The latest known leader epoch.
28 LeaderEpoch: int32
View as plain text