我想使用 Kafka 0.10 API 最好是 Java . 据我所知 kafka_2.11-0.10.0.0.jar 不支持使用以下方法创建代理：
import kafka.cluster.Broker;
import kafka.cluster.Cluster;但我找不到任何这样做的文件。我最近读了[1]，它告诉我们如何使用 Kafka API 在 Java . 我们是否可以做类似的事情来创建代理集群、更新分区、将现有数据/分区迁移到新代理（因为这些新代理不会自动分配任何数据分区，所以除非将分区移动到它们，否则它们不会做任何工作[2]）
[1] 如何使用api从ide创建kafka主题
[2] https://kafka.apache.org/0100/ops.html#basic_ops_cluster_expansion
1条答案
按热度按时间qlvxas9a1#
我有一些你可能会发现有用的示例代码。
要创建代理，请查看kafkatestserver。它实际上是为了更简单的测试，所以它不创建集群，只创建一个代理，但扩展起来应该并不困难。
一旦我在测试服务器中建立了创建/查询/删除主题的功能，我就创建了一个独立的管理客户机，用于对其他服务器执行相同的操作，因此如果您已经在创建代理集群，您应该能够使用代码来维护其上的主题。看一看Kafka德姆林特。
admin客户机基本上是一个围绕scala kafka.admin.adminutils类的纯java Package 器，因此它可以处理所有scala<-->java转换。