9.2.4. コネクターの作成
この手順では、Kafka Connect REST API を使用して分散モードで Kafka Connect で使用するコネクタープラグインを作成する方法を説明します。
前提条件
- 分散モードで実行する Kafka Connect インストール。
手順
コネクター設定で JSON ペイロードを準備します。以下に例を示します。
Copy to Clipboard Copied! Toggle word wrap Toggle overflow POST リクエストを
<KafkaConnectAddress>:8083/connectors
に送信してコネクターを作成します。以下の例では、curl
を使用します。curl -X POST -H "Content-Type: application/json" --data @sink-connector.json http://connect0.my-domain.com:8083/connectors
curl -X POST -H "Content-Type: application/json" --data @sink-connector.json http://connect0.my-domain.com:8083/connectors
Copy to Clipboard Copied! Toggle word wrap Toggle overflow <KafkaConnectAddress>:8083/connectors
に GET リクエストを送信して、コネクターがデプロイされたことを確認します。以下の例では、curl
を使用します。curl http://connect0.my-domain.com:8083/connectors
curl http://connect0.my-domain.com:8083/connectors
Copy to Clipboard Copied! Toggle word wrap Toggle overflow