1// CreatePartitionsRequest creates additional partitions for topics.
2CreatePartitionsRequest => key 37, max version 3, flexible v2+, admin
3 // Topics contains topics to create partitions for.
4 Topics: [=>]
5 // Topic is a topic for which to create additional partitions for.
6 Topic: string
7 // Count is the final count of partitions this topic must have after this
8 // request. This must be greater than the current number of partitions.
9 Count: int32
10 // Assignment is a two-level array, the first corresponding to new
11 // partitions, the second contining broker IDs for where new partition
12 // replicas should live.
13 //
14 // The second level, the replicas, cannot have duplicate broker IDs (i.e.
15 // you cannot replicate a single partition twice on the same broker).
16 // Additionally, the number of replicas must match the current number of
17 // replicas per partition on the topic.
18 //
19 // The first level's length must be equal to the delta of Count and the
20 // current number of partitions.
21 Assignment: nullable[=>]
22 // Replicas are replicas to assign a new partition to.
23 Replicas: [int32]
24 TimeoutMillis
25 // ValidateOnly is makes this request a dry-run; everything is validated but
26 // no partitions are actually created.
27 ValidateOnly: bool
28
29// CreatePartitionsResponse is returned from a CreatePartitionsRequest.
30CreatePartitionsResponse =>
31 ThrottleMillis(1)
32 // Topics is a response to each topic in the creation request.
33 Topics: [=>]
34 // Topic is the topic that partitions were requested to be made for.
35 Topic: string
36 // ErrorCode is the error code returned for each topic in the request.
37 //
38 // NOT_CONTROLLER is returned if the request was not issued to a Kafka
39 // controller.
40 //
41 // TOPIC_AUTHORIZATION_FAILED is returned if the client is not authorized
42 // to create partitions for a topic.
43 //
44 // INVALID_REQUEST is returned for duplicate topics in the request.
45 //
46 // INVALID_TOPIC_EXCEPTION is returned if the topic is queued for deletion.
47 //
48 // REASSIGNMENT_IN_PROGRESS is returned if the request was issued while
49 // partitions were being reassigned.
50 //
51 // UNKNOWN_TOPIC_OR_PARTITION is returned if the broker does not know of
52 // the topic for which to create partitions.
53 //
54 // INVALID_PARTITIONS is returned if the request would drop the total
55 // count of partitions down, or if the request would not add any more
56 // partitions, or if the request uses unknown brokers, or if the request
57 // assigns a different number of brokers than the increase in the
58 // partition count.
59 ErrorCode: int16
60 // ErrorMessage is an informative message if the topic creation failed.
61 ErrorMessage: nullable-string
View as plain text