Kafka到Snowflake的连接问题
Kafka到Snowflake的连接问题
提问于 2020-08-30 15:45:10
我正在尝试从本地独立的融合Kafka主题连接到Snowflake表。我通过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，用户名，私钥无效。它们都是有效的，因为我可以使用相同的通过Snowflake web ui登录。
回答 2
Stack Overflow用户
发布于 2020-08-30 20:47:43
对此进行故障排除的一些想法：
这可能是在您准备此问题时发生的，因此请仔细检查它们。
- 将表名设置为全部大写。
- 您的snowflake帐户不应包含https://前缀。这些链接中的示例：
https://docs.snowflake.com/en/user-guide/kafka-connector-install.html
我希望这个helps...Rich
附注：如果此(或其他)答案对您有帮助，请花点时间通过单击答案旁边的复选标记将其从“灰色显示”切换到“已填充”，从而“接受”该答案。
Stack Overflow用户
发布于 2021-11-22 17:30:20
您应该删除智能引号，并使用正常的引号，如‘nowlake.url.name’=‘my.domain.com:443’，
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/63655145
复制相关文章
相似问题
腾讯云开发者
