apache-kafka - 雪花连接器“无法连接到雪花”
问题描述
我正在与 Kafka 合作并尝试将雪花与它连接,但它没有连接。它给出了某种区域错误,服务器和集群应该在同一个区域,我在本地 Kafka 上尝试过并且不接受“snowflake.url.name”。
这是分布式模式下的配置文件。
curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" localhost:8083/connectors/ -d '
{
"name":"XYZCompanySensorData",
"config":{
"connector.class":"com.snowflake.kafka.connector.SnowflakeSinkConnector",
"tasks.max":"2",
"topics":"MysqlJConfluent.source.user_details",
"buffer.count.records":"10000",
"buffer.flush.time":"60",
"buffer.size.bytes":"5000000",
"snowflake.url.name":"fk79721.europe-west2.gcp.snowflakecomputing.com",
"snowflake.user.name":"********",
"snowflake.private.key":"********************************************",
"snowflake.database.name":"DEMO_DB",
"snowflake.schema.name":"PUBLIC",
"key.converter":"org.apache.kafka.connect.storage.StringConverter",
"value.converter":"com.snowflake.kafka.connector.records.SnowflakeAvroConverter"
}
}'
日志文件:
HTTP/1.1 100 Continue
HTTP/1.1 400 Bad Request
Date: Wed, 28 Apr 2021 11:50:41 GMT
Content-Type: application/json
Content-Length: 368
Server: Jetty(9.4.33.v20201020)
{"error_code":400,"message":"Connector configuration is invalid and contains the following 3 error(s):\nsnowflake.url.name: Cannot connect to Snowflake\nsnowflake.user.name: Cannot connect to Snowflake\nsnowflake.private.key: Cannot connect to Snowflake\nYou can also find the above list of errors at the endpoint `/connector-plugins/{connectorType}/config/validate`"}
请让我知道如何连接。
解决方案
这一行:
"snowflake.url.name":"fk79721.europe-west2.gcp.snowflakecomputing.com
表明你没有关闭引号,它应该是这样的:
"snowflake.url.name":"fk79721.europe-west2.gcp.snowflakecomputing.com:443"
推荐阅读
- vue.js - Vue国家和州选择与select2
- mysql - 无法访问strapi中的相关表
- wordpress - 如何在 Azure 中跨多个 VM 同步 wordpress wp-content 目录?
- django - Django Paginator 显示帖子标题而不是页码,为什么?
- ubuntu - 在 Ubuntu 18.04 上安装 GNU m4 1.4.19
- xpath - 有没有办法仅使用 XPATH 1.0 将多个相同命名的属性与正则表达式字符串匹配?
- filter - Microsoft 图形 API - 无法在“toRecipients”数组中使用 $filter 操作
- python - Python/Pandas:日期对象转换为多索引中的时间戳
- amazon-web-services - 使用 SCP 命令将日志从 Linux 服务器下载到本地机器
- autodesk-forge - 是否可以使用 Autodesk forge 识别 BIM 模型的内部和外部元素?