使用文件(Curl)在Kafka模式注册表中创建新条目

{
  "name": "my-connector",
  "config": {
    "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
    "tasks.max": "1",
    "connection.url": "jdbc:mysql://localhost:3306/mydb",
    "connection.user": "user",
    "connection.password": "password",
    "mode": "incrementing",
    "incrementing.column.name": "id",
    "topic.prefix": "my-topic-"
  }
}

curl -X POST -H "Content-Type: application/json" --data @my-connector.json http://localhost:8083/connectors

{"name": "my-connector", "config": {...}, "tasks": [], "type": "source"}