Apache-kafka-tools
提供:Dev Guides
Apache Kafka-ツール
「org.apache.kafka.tools。*」の下にパッケージ化されたKafkaツール。 ツールは、システムツールとレプリケーションツールに分類されます。
システムツール
システムツールは、run classスクリプトを使用してコマンドラインから実行できます。 構文は次のとおりです-
システムツールのいくつかは以下に記載されています-
- * Kafka移行ツール*-このツールは、あるバージョンから別のバージョンにブローカーを移行するために使用されます。
- ミラーメーカー-このツールは、1つのKafkaクラスターを別のクラスターにミラーリングするために使用されます。
- Consumer Offset Checker -このツールは、指定された一連のトピックおよびコンシューマグループのコンシューマグループ、トピック、パーティション、オフセット、logSize、所有者を表示します。
複製ツール
Kafkaレプリケーションは、高レベルの設計ツールです。 レプリケーションツールを追加する目的は、耐久性と可用性を高めることです。 複製ツールのいくつかは以下に記載されています-
- トピックツールの作成-これにより、デフォルトのパーティション数、レプリケーションファクターでトピックが作成され、Kafkaのデフォルトスキームを使用してレプリカの割り当てが行われます。
- トピックトピックツール-このツールは、トピックの特定のリストの情報をリストします。 コマンドラインでトピックが提供されていない場合、ツールはZookeeperに照会してすべてのトピックを取得し、それらの情報をリストします。 ツールが表示するフィールドは、トピック名、パーティション、リーダー、レプリカ、isrです。
- Add Partition Tool -トピックの作成、トピックのパーティション数を指定する必要があります。 トピックのボリュームが大きくなると、後でトピックにさらにパーティションが必要になる場合があります。 このツールは、特定のトピックにさらにパーティションを追加するのに役立ち、追加されたパーティションのレプリカの手動割り当ても可能にします。