在Java中增加主题的分区数

Question

我正在使用名称:kafka2.12版本:2.3.0。根据流量/负载，我想更改主题的最大分区数。Kafka一上来，有没有可能做这种改变，用代码能做到吗？

Answer 1

是的，您可以按代码增加分区。使用AdminClient.CreatePartitions方法。

AdminClients.CreatePartitions方法API文档

public abstract CreatePartitionsResult createPartitions(java.util.Map<java.lang.String,NewPartitions> newPartitions,CreatePartitionsOptions options)

根据相应的值增加作为newPartitions的键给定的主题的分区数。如果为具有键的主题增加分区，则会影响分区逻辑或消息的排序。

public static void createPartitions(String topicName, int numPartitions) {
    Properties props = new Properties();
    props.put("bootstrap.servers","localhost:9092");
    AdminClient adminClient = AdminClient.create(props);

    Map<String, NewPartitions> newPartitionSet = new HashMap<>();
    newPartitionSet.put(topicName, NewPartitions.increaseTo(numPartitions));
    adminClient.createPartitions(newPartitionSet);
    adminClient.close();
}