1// AlterReplicaLogDirsRequest requests for log directories to be moved
2// within Kafka.
3//
4// This is primarily useful for moving directories between disks.
5AlterReplicaLogDirsRequest => key 34, max version 2, flexible v2+
6 // Dirs contains absolute paths of where you want things to end up.
7 Dirs: [=>]
8 // Dir is an absolute path where everything listed below should
9 // end up.
10 Dir: string
11 // Topics contains topics to move to the above log directory.
12 Topics: [=>]
13 // Topic is a topic to move.
14 Topic: string
15 // Partitions contains partitions for the topic to move.
16 Partitions: [int32]
17
18// AlterReplicaLogDirsResponse is returned from an AlterReplicaLogDirsRequest.
19AlterReplicaLogDirsResponse =>
20 ThrottleMillis(1)
21 // Topics contains responses to each topic that had partitions requested
22 // for moving.
23 Topics: [=>]
24 // Topic is the topic this array slot corresponds to.
25 Topic: string
26 // Partitions contains responses to each partition that was requested
27 // to move.
28 Partitions: [=>]
29 // Partition is the partition this array slot corresponds to.
30 Partition: int32
31 // CLUSTER_AUTHORIZATION_FAILED is returned if the client is not
32 // authorized to alter replica dirs.
33 //
34 // LOG_DIR_NOT_FOUND is returned when the requested log directory
35 // is not in the broker config.
36 //
37 // KAFKA_STORAGE_EXCEPTION is returned when destination directory or
38 // requested replica is offline.
39 //
40 // REPLICA_NOT_AVAILABLE is returned if the replica does not exist
41 // yet.
42 ErrorCode: int16
View as plain text