Not able to register the schema for kafka snowflake connector

user_16747499 0
Viewed 165

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)

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"}

Please help

connector apache-kafka-connect snowflake-cloud-data-platform
2 Answers

Use POST rather than PUT, as in this example:

$ curl -X POST -H "Content-Type: application/json" --data '{"name": "local-file-sink", "config": {"connector.class":"FileStreamSinkConnector", "tasks.max":"1", "file":"test.sink.txt", "topics":"connect-test" }}' http://localhost:8083/connectors
user_77985480 

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"
    }
    }"

user_167474990
Related