使用apachekafka0.10.0api和java创建kafka代理集群

gc0ot86w  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(262)

我想使用 Kafka 0.10 API 最好是 Java . 据我所知 kafka_2.11-0.10.0.0.jar 不支持使用以下方法创建代理:

import kafka.cluster.Broker;
import kafka.cluster.Cluster;

但我找不到任何这样做的文件。我最近读了[1],它告诉我们如何使用 Kafka APIJava . 我们是否可以做类似的事情来创建代理集群、更新分区、将现有数据/分区迁移到新代理(因为这些新代理不会自动分配任何数据分区,所以除非将分区移动到它们,否则它们不会做任何工作[2])
[1] 如何使用api从ide创建kafka主题
[2] https://kafka.apache.org/0100/ops.html#basic_ops_cluster_expansion

qlvxas9a

qlvxas9a1#

我有一些你可能会发现有用的示例代码。
要创建代理,请查看kafkatestserver。它实际上是为了更简单的测试,所以它不创建集群,只创建一个代理,但扩展起来应该并不困难。
一旦我在测试服务器中建立了创建/查询/删除主题的功能,我就创建了一个独立的管理客户机,用于对其他服务器执行相同的操作,因此如果您已经在创建代理集群,您应该能够使用代码来维护其上的主题。看一看Kafka德姆林特。
admin客户机基本上是一个围绕scala kafka.admin.adminutils类的纯java Package 器,因此它可以处理所有scala<-->java转换。

相关问题