Kafka Snowflake连接器无法注册Schema，PUT请求返回405错误求助

根因说明 #

HTTP 405 Method Not Allowed错误的核心原因是请求方法与接口路径不匹配：Kafka Connect的/connectors接口仅支持POST方法创建新连接器，PUT方法仅可用于/connectors/{连接器名称}/config路径来更新已有连接器的配置，你当前用PUT方法请求/connectors路径不符合接口规范。

修复方案 #

方案1：改用POST方法创建连接器 #

直接调整curl的请求方法即可，命令如下：

curl -X POST -H "Content-Type:application/json" --data '{"name": "file-stream-demo-distributed","config":{"connector.class":"com.snowflake.kafka.connector.SnowflakeSinkConnector","topic":"demo-2-distributed","file":"/home/ramakrishnakonda/kafka_2.13-2.8.0/config/connect-distributed.properties"}}' http://localhost:8083/connectors

方案2：调整路径使用PUT方法配置 #

如果需要用PUT方法做幂等性配置，修改请求路径为对应连接器的配置接口即可，命令如下：

curl -X PUT -H "Content-Type:application/json" --data '{"connector.class":"com.snowflake.kafka.connector.SnowflakeSinkConnector","topic":"demo-2-distributed","file":"/home/ramakrishnakonda/kafka_2.13-2.8.0/config/connect-distributed.properties"}' http://localhost:8083/connectors/file-stream-demo-distributed/config

补充排查点 #

如果修改后仍有异常，可检查以下项：

• 确认Kafka Connect服务实际监听端口为8083，无端口占用或映射错误
• 确认提交的连接器配置参数符合SnowflakeSinkConnector的要求，避免后续运行报错

内容的提问来源于stack exchange，提问作者Austin Jackson