通过Postman提交Kafka Connect Sink Connector请求时遇500错误

问题根源 #

Kafka Connect的REST API对创建连接器的请求格式有严格要求：请求体仅允许顶层存在name和config两个字段，所有连接器的具体配置（比如connector.class、tasks.max等）必须嵌套在config对象内部。你之前的请求把所有配置项都放在了顶层，导致API无法识别这些字段，从而抛出500错误。

修正后的请求体 #

把所有连接器配置参数移到config对象中，修正后的JSON如下：

{
  "name": "my-sink-connector",
  "config": {
    "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
    "tasks.max": "1",
    "topics": "dbserver1.my_sourcedb.Persons",
    "key.converter": "org.apache.kafka.connect.json.JsonConverter",
    "value.converter": "org.apache.kafka.connect.json.JsonConverter",
    "connection.url": "jdbc:mysql://localhost:3306/my_destinationdb",
    "table.name.format": "Persons"
  }
}

关键说明 #

• name字段保持在顶层，用于指定连接器的名称
• 所有和连接器功能相关的配置（包括JDBC连接信息、转换器、任务数等）必须全部放入config对象内
• 确保发送POST请求的端点是Kafka Connect的/connectors路径（通常是http://<connect-host>:<port>/connectors）

内容的提问来源于stack exchange，提问作者Chandrashekar V