What is AlterPartitionReassignments?
Moves partition replicas between brokers via kafka-reassign-partitions.sh --execute, for rebalancing or decommissioning. Passing null as the target replica list cancels an in-progress reassignment; reassignments respect throttle.replication.rate.limit to avoid saturating broker network.
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
AlterPartitionReassignmentsRequest v1
TimeoutMs
int32 · 4B
AllowReplicationFactorChange
bool · 1B
tagged
var
Name
string (compact)
tagged
var
PartitionIndex
int32 · 4B
Replicas?
[]int32
tagged
var
Schema & Example
Schema { "TimeoutMs": int32, "AllowReplicationFactorChange": bool, "Topics": [{ "Name": string, "Partitions": [{ "PartitionIndex": int32, "Replicas": [int32]? }] }] }
Example { "TimeoutMs": 30000, "AllowReplicationFactorChange": true, "Topics": [{ "Name": "orders", "Partitions": [{ "PartitionIndex": 3, "Replicas": [0, 1, 2] }] }] }