是否可以将分区添加到Kafka 0.8.2中的现有主题

是否可以将分区添加到Kafka 0.8.2中的现有主题

看来您可以改用以下脚本：

bin/kafka-topics.sh --zookeeper zk_host:port/chroot --alter --topic my_topic_name    --partitions 40

在代码中，看起来他们在做同样的事情：

 AdminUtils.createOrUpdateTopicPartitionAssignmentPathInZK(topic, partitionReplicaList, zkClient, true)

kafka-topics.sh

执行这段代码以及kafka-
add-
partition脚本使用的AddPartitionsCommand。

但是，使用密钥时，您必须注意重新分区：

请注意，分区的一种用例是在语义上对数据进行分区， 添加分区不会更改现有数据的分区，
因此如果消费者依赖该分区，这可能会打扰消费者。就是说，如果对数据进行了分区，

hash(key) %number_of_partitions

则该分区可能会通过添加分区而被打乱，但是Kafka不会尝试以任何方式自动重新分配数据。