Kafka Connect REST API 使用手册

Kafka Connect 作为service提供了 REST API 服务

• 管理 Kafka Connector
• Kafka Connect 集群内部通信

常用命令如下：

• 获取 Connector Worker 信息
  curl -s <URL>:8083/ | jq
• 创建新 Connector （以FileStreamSourceConnector举例）

curl -s -X POST -H "Content-Type: application/json" --data 
 '{"name": "<Connector名字>", 
   "config":
    {"connector.class":"org.apache.kafka.connect.file.FileStreamSourceConnector",
    "key.converter.schemas.enable":"true",
    "file":"demo-file.txt",
    "tasks.max":"1",
    "value.converter.schemas.enable":"true",
    "name":"file-stream-demo-distributed",
    "topic":"demo-distributed",
    "value.converter":"org.apache.kafka.connect.json.JsonConverter",
    "key.converter":"org.apache.kafka.connect.json.JsonConverter"}
 }' 
http://<Kafka Connect Worker URL>:8083/connectors