使用 Apache Kafka 0.10.0 API 和 Java 创建一个 Kafka 代理集群答案

【问题标题】：Create a Kafka brokers cluster using Apache Kafka 0.10.0 API with Java使用 Apache Kafka 0.10.0 API 和 Java 创建一个 Kafka 代理集群
【发布时间】：2016-12-10 02:25:05
【问题描述】：

我想使用Kafka 0.10 API 创建一个代理集群，最好使用Java。据我阅读kafka_2.11-0.10.0.0.jar 确实支持使用创建代理：

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

但我找不到任何这样做的文档。我最近阅读了 [1]，它讲述了如何在 Java 中使用 Kafka API 创建主题。我们可以做类似的事情来创建代理集群、更新分区、将现有数据/分区迁移到新代理（因为这些新代理不会自动分配任何数据分区，因此除非将分区移动到它们不会做任何工作[2]）

[1]How Can we create a topic in Kafka from the IDE using API

[2]https://kafka.apache.org/0100/ops.html#basic_ops_cluster_expansion

【问题讨论】：

标签： java apache-kafka kafka-python

【解决方案1】：

我有一些您可能会觉得有用的示例代码。

要创建代理，请查看KafkaTestServer。确实是为了更简单的测试，所以没有创建集群，只是一个broker，但是应该不难扩展。

一旦我在测试服务器中建立了创建/查询/删除主题的功能，我创建了一个独立的管理客户端来对其他服务器执行相同的操作，因此如果您已经在创建代理集群，您应该能够使用代码来维护它的主题。看看KafkaAdminClient。

管理客户端基本上是围绕 scala kafka.admin.AdminUtils 类的纯 java 包装器，因此它处理所有 scala java 转换。

【讨论】：