4

Kafka 0.10 APIPreferred withを使用してブローカー クラスターを作成したいと考えていますJava。私が読んだ限りでは、以下をkafka_2.11-0.10.0.0.jar使用したブローカーの作成をサポートしています:

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

しかし、そうするためのドキュメントが見つかりません。Kafka API最近、 inを使用してトピックを作成する方法を説明している [1] を読みましたJava。同様のことを行って 、ブローカー クラスターを作成し、パーティションを更新し、既存のデータ/パーティションを新しいブローカーに移行できますか? [2])

[1] API を使用して IDE から Kafka でトピックを作成する方法

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

4

1 に答える 1

-1

役に立つと思われるサンプルコードがいくつかあります。

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

トピックを作成/クエリ/削除する機能をテスト サーバーに組み込んだら、他のサーバーに対して同じことを行うためのスタンドアロンの管理クライアントを作成したので、既にブローカー クラスターを作成している場合は、コードを使用できるはずです。その上でトピックを維持します。KafkaAdminClientを見てください。

管理クライアントは基本的に、scala kafka.admin.AdminUtilsクラスの純粋な Java ラッパーであるため、すべての scala <--> Java 変換を内部で処理します。

于 2016-08-04T12:54:16.383 に答える