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

Kafka BeginQuorumEpoch Response 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

Response Header
message_size int32 · 4B
correlation_id int32 · 4B
BeginQuorumEpochResponse v0
ErrorCode int16 · 2B
Topics array
TopicName string
Partitions array
PartitionIndex int32 · 4B
ErrorCode int16 · 2B
LeaderId int32 · 4B
LeaderEpoch int32 · 4B

Schema & Example

Schema
{
  "ErrorCode": int16,
  "Topics": [{
      "TopicName": string,
      "Partitions": [{
          "PartitionIndex": int32,
          "ErrorCode": int16,
          "LeaderId": int32,
          "LeaderEpoch": int32
      }]
  }]
}
Example
{
  "ErrorCode": 0,
  "Topics": [{
      "TopicName": "orders",
      "Partitions": [{
          "PartitionIndex": 3,
          "ErrorCode": 0,
          "LeaderId": 1,
          "LeaderEpoch": 17
      }]
  }]
}