What is AlterReplicaLogDirs?
Moves replicas to a different disk on the same broker via kafka-reassign-partitions.sh, rebalancing disk usage without cross-broker data movement. The move is asynchronous; use DescribeLogDirs to monitor progress by checking the futureLogDir field.
Wire Diagram
Request Header
message_size
int32 · 4B
api_key
int16 · 2B
api_version
int16 · 2B
correlation_id
int32 · 4B
client_id
string
AlterReplicaLogDirsRequest v1
Path
string
Name
string
Partitions
[]int32
Schema & Example
Schema { "Dirs": [{ "Path": string, "Topics": [{ "Name": string, "Partitions": [int32] }] }] }
Example { "Dirs": [{ "Path": "/var/kafka-logs/orders-3", "Topics": [{ "Name": "orders", "Partitions": [1, 2, 3] }] }] }