1// ListPartitionReassignmentsRequest, proposed in KIP-455 and implemented in
2// Kafka 2.4.0, is a request to list in progress partition reassignments.
3//
4// ACL wise, this requires DESCRIBE on CLUSTER.
5ListPartitionReassignmentsRequest => key 46, max version 0, flexible v0+, admin
6 TimeoutMillis(60000)
7 // Topics are topics to list in progress partition reassignments of, or null
8 // to list everything.
9 Topics: nullable[=>]
10 // Topic is a topic to list in progress partition reassingments of.
11 Topic: string
12 // Partitions are partitions to list in progress reassignments of.
13 Partitions: [int32]
14
15// ListPartitionReassignmentsResponse is returned for a ListPartitionReassignmentsRequest.
16ListPartitionReassignmentsResponse =>
17 ThrottleMillis
18 // ErrorCode is the error code returned for listing reassignments.
19 //
20 // REQUEST_TIMED_OUT is returned if the request timed out.
21 //
22 // NOT_CONTROLLER is returned if the request was not issued to a Kafka
23 // controller.
24 //
25 // CLUSTER_AUTHORIZATION_FAILED is returned if the client is not
26 // authorized to reassign partitions.
27 ErrorCode: int16
28 // ErrorMessage is any global (applied to all partitions) error message.
29 ErrorMessage: nullable-string
30 // Topics contains responses for each topic requested.
31 Topics: [=>]
32 // Topic is the topic being responded to.
33 Topic: string
34 // Partitions contains responses for partitions.
35 Partitions: [=>]
36 // Partition is the partition being responded to.
37 Partition: int32
38 // Replicas is the partition's current replicas.
39 Replicas: [int32]
40 // AddingReplicas are replicas currently being added to the partition.
41 AddingReplicas: [int32]
42 // RemovingReplicas are replicas currently being removed from the partition.
43 RemovingReplicas: [int32]
View as plain text