我正在尝试从本地独立 Confluence 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 使用相同的内容登录。
关于解决此问题的一些想法：
-
您的配置中似乎有一些“智能引号”，请删除智能单引号和双引号，并将其替换为正确的文本引号。这可能是在你准备这个问题的过程中发生的，所以请仔细检查它们。
-
将表名设置为全部大写字母。
-
您的雪花帐户不应包含 https:// 前缀。这些链接中的示例：
https://community.snowflake.com/s/article/Docker-Compose-Setting-up-Kafka-using-Snowflake-Sink-Connector-and-testing-Streams 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 https://docs.snowflake.com/en/user-guide/kafka-connector-install.html
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
