Apache Kafka 0.10.0 API with Javaを使用してKafkaブローカクラスタを作成する

Question

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] 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

Answer 1

私はあなたが役に立つかもしれないいくつかのサンプルコードを持っています。

ブローカーを作成するには、KafkaTestServerをご覧ください。実際には簡単なテストのため、クラスタを作成するのではなく、単一のブローカを作成しますが、拡張するのは難しくありません。

テストサーバーにトピックを作成/クエリ/削除する機能が組み込まれたら、他のサーバーと同じことを行うスタンドアロンの管理クライアントを作成しました。したがって、ブローカクラスタを既に作成している場合は、コードを使用してトピックを管理します。 KafkaAdminClientをご覧ください。カバーの下に> javaの変換 - それはすべてのScalaの<を扱うよう

管理クライアントは、基本的には、Scalaのkafka.admin.AdminUtilsクラスの周りの純粋なJavaのラッパーです。