大佬教程收集整理的这篇文章主要介绍了是否可以将分区添加到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。
但是，使用密钥时，您必须注意重新分区：
我有一个带有2个分区的Kafka集群。我一直在寻找一种将分区数增加到3的方法。但是，我不想丢失该主题中的现有消息。我尝试停止Kafka，修改server.properties文件以将分区数增加到3，然后重新启动Kafka。但是，这似乎并没有改变任何东西。使用Kafka
ConsumerOffsetChecker，我仍然看到它仅使用2个分区。我正在使用的Kafka版本是0.8.2.2。在0.8.1版中，曾经有一个名为的脚本kafka-
add-
partitions.sh，我想可能可以解决问题。但是，我在0.8.2中看不到任何这样的脚本。有什么办法可以做到这一点？我确实尝试过创建一个全新的主题，为此，它似乎确实根据server.properties文件中的更改使用了3个分区。但是，对于现有主题，似乎并不在乎。
以上是大佬教程为你收集整理的是否可以将分区添加到Kafka 0.8.2中的现有主题全部内容，希望文章能够帮你解决是否可以将分区添加到Kafka 0.8.2中的现有主题所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。