我试图连接从本地独立合流Kafka主题到雪花表。我正在通过以下连接器配置 ksqldb .
CREATE SINK CONNECTOR `snowflake_sink` WITH(
"name"='snowflake_sink',
"tasks.max"='1',
"connector.class"='com.snowflake.kafka.connector.SnowflakeSinkConnector',
"topics"='USERPROFILE',
"snowflake.url.name"='https://mybu.mycompany.us-east-1.aws.privatelink.snowflakecomputing.com',
"snowflake.user.name”=‘myuser’,
"snowflake.database.name"='DEMO_DB',
"snowflake.topic2table.map"='USERPROFILE:UK_SF_DB1_Table1',
"snowflake.schema.name"='PUBLIC',
"snowflake.private.key”=‘<valid private key>’,
"snowflake.private.key.passphrase”=‘<valid pass phrase>’,
"key.converter"='org.apache.kafka.connect.storage.StringConverter',
"value.converter"='com.snowflake.kafka.connector.records.SnowflakeJsonConverter',
"key.converter.schema.registry.url"='http://schema-registry:8081',
"value.converter.schema.registry.url"='http://schema-registry:8081');ksqldb抛出错误，表示雪花url、用户名、私钥无效。它们都是有效的，因为我可以登录使用相同的通过雪花网页用户界面。
1条答案
按热度按时间mzsu5hc01#
有关排除此问题的一些想法：
您的配置中似乎有一些“智能引号”，请删除智能单引号和双引号，并用正确的文本引号替换它们。这可能是在你准备这个问题的时候发生的，所以仔细检查一下。
将表名设置为所有大写字母。
您的snowflake帐户不应包含https://前缀。这些链接的示例：
https://community.snowflake.com/s/article/docker-compose-setting-up-kafka-using-snowflake-sink-connector-and-testing-streams
https://docs.snowflake.com/en/user-guide/kafka-connector-install.html
我希望这有助于…rich
p、 如果这个（或另一个）答案对你有帮助，请花点时间“接受”这个答案，方法是点击答案旁边的复选标记，将其从“灰显”切换到“已填写”。