9.2.4. コネクターの作成
この手順では、Kafka Connect REST API を使用して分散モードで Kafka Connect で使用するコネクタープラグインを作成する方法を説明します。
前提条件
- 分散モードで実行する Kafka Connect インストール。
手順
コネクター設定で JSON ペイロードを準備します。以下に例を示します。
{ "name": "my-connector", "config": { "connector.class": "org.apache.kafka.connect.file.FileStreamSinkConnector", "tasks.max": "1", "topics": "my-topic-1,my-topic-2", "file": "/tmp/output-file.txt" } }
POST リクエストを
<KafkaConnectAddress>:8083/connectors
に送信してコネクターを作成します。以下の例では、curl
を使用します。curl -X POST -H "Content-Type: application/json" --data @sink-connector.json http://connect0.my-domain.com:8083/connectors
<KafkaConnectAddress>:8083/connectors
に GET リクエストを送信して、コネクターがデプロイされたことを確認します。以下の例では、curl
を使用します。curl http://connect0.my-domain.com:8083/connectors