Kafka Configs Kafka Protocol Wire Format API Versions KIPs Errors Kafka Upgrade Config Advisor Flink SQL
conduktor.io ↗

Kafka BeginQuorumEpoch Request Wire Format v0 — Binary Protocol Layout

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.

Related Errors

INCONSISTENT_VOTER_SET

Wire Diagram

Request Header
message_size int32 · 4B
api_key int16 · 2B
api_version int16 · 2B
correlation_id int32 · 4B
client_id string
BeginQuorumEpochRequest v0
ClusterId? string
Topics array
TopicName string
Partitions array
PartitionIndex int32 · 4B
LeaderId int32 · 4B
LeaderEpoch int32 · 4B

Schema & Example

Schema
{
  "ClusterId": string?,
  "Topics": [{
      "TopicName": string,
      "Partitions": [{
          "PartitionIndex": int32,
          "LeaderId": int32,
          "LeaderEpoch": int32
      }]
  }]
}
Example
{
  "ClusterId": "dQw4w9WgXcQ",
  "Topics": [{
      "TopicName": "orders",
      "Partitions": [{
          "PartitionIndex": 3,
          "LeaderId": 1,
          "LeaderEpoch": 17
      }]
  }]
}