conduktor.io ↗

Kafka ListPartitionReassignments Request Wire Format v0 — Binary Protocol Layout

What is ListPartitionReassignments?

Checks reassignment progress via kafka-reassign-partitions.sh --verify. Shows current, adding, and removing replica sets per partition. When addingReplicas and removingReplicas are both empty, the reassignment is complete.

Wire Diagram

Request Header · flexible
message_size int32 · 4B
api_key int16 · 2B
api_version int16 · 2B
correlation_id int32 · 4B
client_id string (compact)
tagged var
ListPartitionReassignmentsRequest v0
TimeoutMs int32 · 4B
Topics? array
tagged var
Name string (compact)
PartitionIndexes []int32
tagged var

Schema & Example

Schema
{
  "TimeoutMs": int32,
  "Topics": [{
      "Name": string,
      "PartitionIndexes": [int32]
  }]?
}
Example
{
  "TimeoutMs": 30000,
  "Topics": [{
      "Name": "orders",
      "PartitionIndexes": [1, 2, 3]
  }]?
}