8.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
