是否可以在Kafka 0.8.2中为现有主题添加分区
- 有什么方法实现这一点吗？
我尝试创建了一个全新的主题，对于这个主题，它似乎使用了3个分区，这与server.properties文件中的更改一致。然而，对于已有的话题，它似乎并不在意。
共有1个答案
看来您可以改用以下脚本：
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，修改文件以将分区数增加到3，然后重新启动Kafka。但是，这似乎并没有改变任何东西。使用Kafka ，我仍然看到它仅使用2个分区。我正在使用的Kafka版本是0.8.2.2。在0.8.1版中，曾经有一个名为的脚本，我想可能可以解决问题。但是，我在0.8
-
问题内容： 例如，如果我有两个对象： 和 我想将x和y值从foo转移到oof。有没有办法使用es6解构语法来做到这一点？ 也许像这样： 问题答案： 虽然丑陋且有点重复，但您可以 它将读取对象的两个值，并将它们写入对象上它们各自的位置。 就个人而言，我还是想读 要么 虽然。
-
我正在尝试使用python wget下载URL，下载地址为：https://pypi.python.org/pypi/wget 这个包不支持超时选项，因此查询失败大约需要一些时间（大约10秒）。是否可以在try块中添加超时以减少函数的等待时间。 大概是这样的：
-
我的应用程序调用了一堆不同的外部API类。为了便于这样做，我为每个要调用的外部API设置了一个类，所有这些类都继承自一个基类，该基类的开头如下所示： 是否没有办法在现有对象上设置凭据，或者没有进行大量重构的其他方法？
-
问题内容： 在Java中有可能发生这种情况吗？可以为Java中的枚举元素分配自定义数值吗？ 问题答案：
-
现在我需要将一个结果按一些字段分组。 如何将count和groupBy添加到规范中的问题？或者，也许我需要创建一个谓词，在其中定义这个count和groupBy（不知何故），并为此制定一个规范？做这件事的更好的方法是什么？ 更新#0 我尝试使用multiselect，但它还是选择了所有列。 如果我使用来定义要选择的列，它就可以工作，但是我需要它使用criteries API/specificati