缺少所需的配置“名称”尝试Kafka时没有默认值

Question

我的配置/sf_connect.properties文件

tasks.max=8
topics=topic1,topic2
snowflake.topic2table.map= topic1:table1,topic2:table2
buffer.count.records=10000
buffer.flush.time=60
buffer.size.bytes=5000000
snowflake.url.name=myorganization-myaccount.snowflakecomputing.com:443
snowflake.user.name=jane.smith
snowflake.private.key=xyz123
snowflake.private.key.passphrase=jkladu098jfd089adsq4r
snowflake.database.name=mydb
snowflake.schema.name=myschema
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=com.snowflake.kafka.connector.records.SnowflakeAvroConverter
value.converter.schema.registry.url=http://localhost:8081
value.converter.basic.auth.credentials.source=USER_INFO
value.converter.basic.auth.user.info=jane.smith:MyStrongPassword

如下 丢失所需的配置“名称”，在尝试Kafka连接到雪花上没有默认值

Snowflake的正式文档指示名称是必需的参数。因此，我在上面的文件中添加了一个name = somerandomname。它仍然不起作用。

这是完整的日志，即使是私钥和密码也无效（需要与管理员核对），

java.util.concurrent.ExecutionException: org.apache.kafka.connect.runtime.rest.errors.BadRequestException: Connector configuration is invalid and contains the following 3 error(s):
Missing required configuration "name" which has no default value.
snowflake.private.key is not valid
snowflake.private.key.passphrase is not valid

都需要上述一些帮助。官方文档链接在这里 https> https：// docs。 snowflake.com/en/user-guide/kafka-connector-install.html#configuring-the-kafka-connector

Answer 1

您仍然需要在文档中遵循“使用密钥对身份验证”部分，并在sf_connect.properties和snowflake中提供snowflake.private.key向kafka用户提供。例如：Alter用户JSMITH设置rsa_public_key ='miibibijanbgkqh ...';