9.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 を実行する場合は、プラグインをすべてのワーカーノードで利用できるようにする必要があります。