Apache-kafka-tools

Apache Kafka-ツール

「org.apache.kafka.tools。*」の下にパッケージ化されたKafkaツール。 ツールは、システムツールとレプリケーションツールに分類されます。

システムツール

システムツールは、run classスクリプトを使用してコマンドラインから実行できます。 構文は次のとおりです-

bin/kafka-run-class.sh package.class - - options

システムツールのいくつかは以下に記載されています-

• * Kafka移行ツール*-このツールは、あるバージョンから別のバージョンにブローカーを移行するために使用されます。
• ミラーメーカー-このツールは、1つのKafkaクラスターを別のクラスターにミラーリングするために使用されます。
• Consumer Offset Checker -このツールは、指定された一連のトピックおよびコンシューマグループのコンシューマグループ、トピック、パーティション、オフセット、logSize、所有者を表示します。

複製ツール

Kafkaレプリケーションは、高レベルの設計ツールです。 レプリケーションツールを追加する目的は、耐久性と可用性を高めることです。 複製ツールのいくつかは以下に記載されています-

• トピックツールの作成-これにより、デフォルトのパーティション数、レプリケーションファクターでトピックが作成され、Kafkaのデフォルトスキームを使用してレプリカの割り当てが行われます。
• トピックトピックツール-このツールは、トピックの特定のリストの情報をリストします。 コマンドラインでトピックが提供されていない場合、ツールはZookeeperに照会してすべてのトピックを取得し、それらの情報をリストします。 ツールが表示するフィールドは、トピック名、パーティション、リーダー、レプリカ、isrです。
• Add Partition Tool -トピックの作成、トピックのパーティション数を指定する必要があります。 トピックのボリュームが大きくなると、後でトピックにさらにパーティションが必要になる場合があります。 このツールは、特定のトピックにさらにパーティションを追加するのに役立ち、追加されたパーティションのレプリカの手動割り当ても可能にします。