8.3. コネクタープラグイン

AMQ Streams には、以下のコネクタープラグインが含まれています。

FileStreamSink Kafka トピックからデータを読み込み、データをファイルに書き込みます。

FileStreamSource ファイルからデータを読み込み、データを Kafka トピックに送信します。

必要に応じて、コネクタープラグインを追加できます。Kafka Connect は、起動時に追加のコネクタープラグインを検索し、実行します。kafka Connect がプラグインを検索するパスを定義するには、plugin.path configuration オプションを設定します。

plugin.path=/opt/kafka/connector-plugins,/opt/connectors

plugin.path 設定オプションには、パスのコンマ区切りリストを含めることができます。

分散モードで Kafka Connect を実行する場合、プラグインはすべてのワーカーノードで利用可能である必要があります。