What is BeginQuorumEpoch?
The newly elected KRaft leader sends this to all quorum voters to establish itself for the new epoch. Metadata writes pending from the old epoch will be replicated or dropped based on the new leader's log end offset.
| Version | Kafka | Changes |
|---|---|---|
| BeginQuorumEpochRequest | ||
| v0 | 2.7 | + ClusterId string+ Topics []TopicData+ TopicName string+ Partitions []PartitionData+ PartitionIndex int32+ LeaderId int32+ LeaderEpoch int32 |
| v1 | 3.9 | + VoterId int32+ VoterDirectoryId uuid+ LeaderEndpoints []LeaderEndpoint+ Name string+ Host string+ Port uint16~ Flexible encoding enabled FLEXIBLE adds flexible versions, voter key and leader endpoints (KIP-853) |
| BeginQuorumEpochResponse | ||
| v0 | 2.7 | + ErrorCode int16+ Topics []TopicData+ TopicName string+ Partitions []PartitionData+ PartitionIndex int32+ ErrorCode int16+ LeaderId int32+ LeaderEpoch int32 |
| v1 | 3.9 | + NodeEndpoints []NodeEndpoint+ NodeId int32+ Host string+ Port uint16~ Flexible encoding enabled FLEXIBLE adds flexible versions and leader endpoint (KIP-853) |