{
"name": "my-sink-connector",
"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"
}
显示以下错误:
"error_code": 500, "message": "Unrecognized field "connector.class" (班级 org.apache.kafka.connect.runtime.rest.entities.CreateConnectorRequest), 未标记为可忽略(2 个已知属性:“配置”、“名称”]) 在 [来源: (org.glassfish.jersey.message.internal.ReaderInterceptorExecutor$UnCloseableInputStream); 行:10,列:2](通过参考链: org.apache.kafka.connect.runtime.rest.entities.CreateConnectorRequest["connector.class"]