kafka-通过ConFluent REST Api增加现有主题的分区计数
我需要向现有的Kafka主题添加分区。我知道可以使用bin/kafka主题。sh脚本来实现这一点，但我更愿意通过融合的RESTAPI来实现这一点。
据我所见，api引用中没有记录在案的endpoint，但我想知道这里是否有其他人能够做到这一点。
编辑：由于在这里似乎不可能使用REST api，我想知道在容器化设置中向现有主题添加分区的最佳实践是什么。例如，如果有将客户ID映射到特定分区的自定义分区方案。在这种情况下，应用程序容器需要调整kafka容器的分区计数。
共有1个答案
合流REST代理没有用于主题更新管理的此类endpoint。
您需要使用外壳脚本或外壳脚本使用的相应AdminClient类
-
我是Apache Kafka的一个新用户，我还在了解它的内部结构。 在我的用例中，我需要从Kafka Producer客户端动态增加一个主题的分区数量。 我发现了关于增加分区大小的其他类似问题，但它们使用了zookeeper配置。但是我的kafkaProducer只有Kafka broker配置，而没有zookeeper配置。 有没有什么方法我可以增加一个主题的分区数量从生产者端？我运行的是Kaf
-
问题内容： 如何从代码中获取任何kafka主题的分区数。我研究了许多链接，但似乎没有一个起作用。 提及一些： http://grokbase.com/t/kafka/users/148132gdzk/find-topic-partition-count- through-simpleclient-api http://grokbase.com/t/kafka/users/151cv3htga/ge
-
我使用的是Kafka 0.8.2，而我的使用者却出现了一个错误：“OFFSET commit FAILL with...”。当查看主题“__consumer_offsets”时。我看到它有50个分区计数。正常吗？我只能通过删除所有的Kafka日志并重新启动我的Kafka服务器来解决这个问题。是否有一种方法，我可以删除这个主题时，它达到一定数量的分区，还是我提交的偏移量是错误的？ 下面是我提交偏移的
-
Kafka主题分区偏移位置始终从0或随机值开始，如何确保使用者记录是分区中的第一条记录？有没有办法找出答案？如果有的话，请让我知道。谢谢。
-
我正在使用名称:kafka2.12版本:2.3.0。根据流量/负载，我想更改主题的最大分区数。Kafka一上来，有没有可能做这种改变，用代码能做到吗？
-
简单问题： 假设我有一个具有3个分区的主题：Topic：StateEvents P1、P2和P3。 让我们假设生产者生成20条消息： 1, 2, 3, ..........20 我的问题是: 当制作人生成这些消息时： 1）每个消息将只在且仅在1个分区？也就是说，1在P1,2在P2,3在P3，然后4在P1,5在P2,6在P3，以此类推？ 2）如果#1为真，当消费者订阅时，它将订阅所有分区，以便获得所