Increase the number of partitions of the topics according to the corresponding values. If partitions are increased for a topic that has a key, the partition logic or ordering of the messages will be affected. It may take several seconds after this method returns success for all the brokers to becom
(topic string, count int32, assignment [][]int32, validateOnly bool)
| 44 | // During this time, ClusterAdmin#describeTopics may not return information about the |
| 45 | // new partitions. This operation is supported by brokers with version 1.0.0 or higher. |
| 46 | CreatePartitions(topic string, count int32, assignment [][]int32, validateOnly bool) error |
| 47 | |
| 48 | // Alter the replica assignment for partitions. |
| 49 | // This operation is supported by brokers with version 2.4.0.0 or higher. |
no outgoing calls