无法为 kafka 雪花连接器注册架构 [英] Not able to register the schema for kafka snowflake connector

问题描述

分布式服务启动成功:[2021-10-17 18:04:29,693] 信息开始 o.e.j.s.ServletContextHandler@1422ac7f{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:916)[2021-10-17 18:04:29,693] INFO REST 资源初始化；服务器已启动并准备好处理请求 (org.apache.kafka.connect.runtime.rest.RestServer:319)[2021-10-17 18:04:29,693] INFO Kafka Connect 启动 (org.apache.kafka.connect.runtime.Connect:57)

Distributed Services Got Started Successfully: [2021-10-17 18:04:29,693] INFO Started o.e.j.s.ServletContextHandler@1422ac7f{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:916) [2021-10-17 18:04:29,693] INFO REST resources initialized; server is started and ready to handle requests (org.apache.kafka.connect.runtime.rest.RestServer:319) [2021-10-17 18:04:29,693] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:57)

但无法创建架构注册表:curl -X PUT -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/连接器{"error_code":405,"message":"HTTP 405 Method Not Allowed"}

But not able to make schema registry: curl -X PUT -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 {"error_code":405,"message":"HTTP 405 Method Not Allowed"}

请帮忙

推荐答案

curl -X POST "http://localhost:8083/connectors" -H "Content-    type:application/json" --data 
    "{
    "name":"file-stream-demo-distributed",
    "config":{
    "connector.class":"com.snowflake.kafka.connector.SnowflakeSinkConnector",
    "tasks.max":"1",
    "topics":"demo-2-distributed",
    "buffer.count.records":"10000",
    "buffer.flush.time":"60",
    "buffer.size.bytes":"5000000",
    "snowflake.url.name":"XXXXXXXX.XXXXXXXXX.snowflakecomputing.com:443",
    "snowflake.user.name":"kafka_connector_user_1",
   "snowflake.private.key":"XXXXXXXXXXXXXXXXXXX+XXXXXXXXXXXXXXXXXXXXXXXXXXXXX,
    "snowflake.database.name":"KAFKA_DB",
    "snowflake.schema.name":"KAFKA_SCHEMA",
    "key.converter":"org.apache.kafka.connect.storage.StringConverter",
    "key.converter.schemas.enable":"true",                                           "value.converter":"com.snowflake.kafka.connector.records.SnowflakeJsonConverter",
    "value.converter:schemas.enable":"true",
    "value.converter.schema.registry.url":"http://localhost:8081"
    }
    }"

这篇关于无法为 kafka 雪花连接器注册架构的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！