我已经设置了雪花-卡夫卡连接器。我在snowflake中设置了一个示例表(kafka_connector_test)，两个字段都是VARCHAR型的。下面是我为连接器创建的配置 curl -X POST \ --data '{"valu
浏览 4提问于2020-07-03得票数 0
回答已采纳
2回答
我正在尝试从本地独立的融合Kafka主题连接到Snowflake表。我通过ksqldb使用以下连接器配置。"='com.snowflake.kafka.connector.SnowflakeSinkConnector',"snowflake.url.name”=‘<valid pass phrase>’,
&qu
浏览 0提问于2020-08-30得票数 2
(代表Snowflake客户端提交...) .. 我正在尝试使用Kafka的snowflake连接器连接Kafka和Snowflake。参考本文档：https://docs.snowflake.net/manuals/user-guide/kafka-connector.html 当我运行Kafka时，它正在初始化Snowflake
浏览 76提问于2019-10-11得票数 0
回答已采纳
我有一个从kafka摄取数据到Snowflake的要求。我想用snowflake kafka连接器来设计这个摄取。我的理解是，我的接收器需要是一个variant表，所以连接器会将kafka消息推送到variant列。一旦数据在variant列中，我将需要运行另一个进程来读取variant列，解析它并将数据存储到相应的目标表中。请让我知道这是否是摄取kafk
浏览 33提问于2020-07-29得票数 0
回答已采纳
有人能告诉我为什么我的snowflake.topic2table.map值被我的雪花水槽连接器报告为无效吗？KAFKA_TEST数据库已经在雪花中创建，我可以让接收器连接器为我创建表。当我从配置中删除snowflake.topic2table.map设置时，它工作正常.但是我想控制正在创建的表的名称。我使用的汇合5.3.1和雪花连接器0.50。[SF_KAFKA_CONNECTOR
浏览 2提问于2019-10-06得票数 1
回答已采纳
2回答
试图连接到Kafka集群并从一个主题向雪花写入数据。type=sink, typeName='sink', location='file:path_to_kafka/kafka_2.12-2.3.0/libs/snowflakeinc-snowflake-kafka-connector/'}
我用来运行的命令(不包括标准的动物园管理员/ kafka</em
浏览 6提问于2019-12-13得票数 1
1回答
具有汇合云区错误的雪花连接器
、、、、
我正在使用confluent，并试图连接MySQL作为源，它确实连接了，但当我尝试连接snowflake时，它给了我一个区域错误。下面是confluent中的连接器配置 Connector SummarySnowflakeSinkConnector_0SnowflakeSinkkafka.api.secret
*************************************************
浏览 18提问于2021-04-30得票数 0
我有一个在Confluent Cloud中运行的集群，并且能够使用其他应用程序生成和使用数据。然而，当我尝试连接Snowflake Kafka连接器时，我收到以下错误：[SF_KAFKA_CONNECTOR] Snowflake Kafka Conn
浏览 0提问于2019-10-16得票数 2
在kafka中，创建mysql连接的请求主体如下： "name": "inventory-connector", { "config": {
"connector.class":
浏览 2提问于2021-06-24得票数 0
回答已采纳
1回答
试图建立雪花卡夫卡连接，它似乎失败了，没有抛出任何有用的日志
com.snowflake.kafka.connector.SnowflakeSinkConnector (org.apache.kafka.connect.runtime.Worker0 (com.snowflake.kafka.connector.Utils:99) 2021-04-07 21:09:25,092警告SF_KAFKA_CONNECTOR连接器更新，请升级
浏览 3提问于2021-04-07得票数 0
我正在使用雪花的Kafka连接器将一些数据输入到一个表中。我可以看到舞台上的文件(当我运行LIST @STAGE_NAME;时)。据SYSTEM$PIPE_STATUS称，这条管道正在运行。不过，我没有看到复制历史上的任何东西。但是，当我刷新管道时，我会看到表被填充了一点。{
"buffer.count.records": "2&quo
浏览 4提问于2022-04-06得票数 0
回答已采纳
1回答
我正在遵循本指南中的步骤BadRequestException:连接器配置{.}不包含连接器类型sh kafka_2.12-2.3.0/bin/connect-standalone.shconnect-standalone.properties snowflake_kafka_config.jsonconnect-standalone.properties
bootstrap
浏览 0提问于2019-10-15得票数 0
回答已采纳
":{"connector.class":"com.snowflake.kafka.connector.SnowflakeSinkConnector","tasks.max":"1","topics":":"XXX00000.XX-XXXX-0.snowflakecomputing.com:443","snowflake.user.name":"kafka
浏览 7提问于2022-05-29得票数 0
我已经在本地启动了Kafka (2.8.0版)，并且正在运行Connect并得到这个输出。
如何启动Snowflake连接器？Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.RootResourceWARNING:
浏览 0提问于2021-10-13得票数 1
我们正在尝试使用Kafka连接到Snowflake数据库。根据下面的支持文档，我们已经创建了配置文件。我们使用JSON格式作为使用kafka的snowflake的有效负载输入。":"xxxx.snowflakecomputing.com:443", "sn
浏览 1提问于2020-06-22得票数 0
任何人都可以帮助我消耗连续数据中的数据，这些数据正在被流式传输。在snowflake连接器中应该为主题提供什么？
因为我能够使用所需的主题名称通过单个表数据填充数据。但我有捕获连续数据流到表中的要求。
浏览 0提问于2021-10-07得票数 5
我试图创建一个卡夫卡连接器从卡夫卡到雪花使用卡夫卡到雪花部分的这个。 -d '{ "value.converter":&
浏览 7提问于2022-01-12得票数 0
我正在与Kafka合作，并试图将snowflake与它联系起来，但它不能连接。它给出了某种区域错误，即服务器和集群应该在同一个区域上，我在本地Kafka上尝试了一下，但不接受"snowflake.url.name“。 这是分布式模式下的配置文件。localhost:8083/connectors/ -d ' "name":"XYZCompanySensorData",
"config&q
浏览 53提问于2021-04-29得票数 0
1回答
我试图通过kafka连接器将467个主题上的大约2797个分区推送到snowflake，而(2个任务) kafka连接器使用：
[2020-03-08 10:13:10,884] ERROR WorkerSinkTask{id=snowflake-1} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask&l
浏览 31提问于2020-03-08得票数 1
1回答
command getting error: 得到错误，因为我的卡夫卡-动物园管理员，卡夫卡服务和分布式连接服务正在启动和运行:[SF_KAFKA_CONNECTOR] Error Code: 1001
[SF_KAF
浏览 13提问于2022-05-26得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
