且构网

分享程序员开发的那些事...
且构网 - 分享程序员编程开发的那些事

无法为 kafka 雪花连接器注册架构

更新时间:2023-01-17 21:51:23

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