通过POST请求创建OCI流Source Connector时遇字段未识别错误

错误原因 #

Kafka Connect的REST API创建连接器时，要求所有连接器配置参数（如connector.class、tasks.max）必须嵌套在config对象中，而非与name字段同级。你的请求将这些参数放在顶层，导致API无法识别connector.class字段，进而抛出500错误。

修正后的请求JSON #

将所有连接器配置项移入config字段内，正确的请求格式如下：

{
  "name": "dupe-check-source-connector",
  "config": {
    "connector.class":"com.oracle.oci.kafka.connect.source.OciStreamingSourceConnector",
    "tasks.max":"1"
    // 需补充OCI流的其他必填配置，例如stream.ocid等参数
  }
}

额外注意事项 #

• 确认OCI Kafka Connect连接器的JAR包已放置在Kafka Connect的plugin.path指定目录（未配置则放在Kafka的libs目录），否则Connect无法找到connector.class对应的类。
• 检查connect-distributed.properties中的配置正确性，尤其是OCI流的SASL认证信息，确保能正常连接到OCI流服务。

内容的提问来源于stack exchange，提问作者alex zubin