连接器0.5.1中的错误消息为
启动连接器(org.apache.kafka.connect.runtime.WorkerConnector:119)测试时出现错误测试{id=Snowflake-kafka-WorkerConnector}错误: org/bouncycastle/jce/provider/BouncyCastleProvider
浏览 46提问于2019-10-22得票数 0
我有一个在Confluent Cloud中运行的集群，并且能够使用其他应用程序生成和使用数据。然而，当我尝试连接Snowflake Kafka连接器时，我收到以下错误：[SF_KAFKA_CONNECTOR] Snowflake Kafka Connector Ver
浏览 0提问于2019-10-16得票数 2
1回答
试图建立雪花卡夫卡连接，它似乎失败了，没有抛出任何有用的日志
com.snowflake.kafka.connector.SnowflakeSinkConnector (org.apache.kafka.connect.runtime.Worker:202) 2021-04-07 21:25,028 INFO实例化连接器TEST_CONNECTOR，类型为com.snowflake.kafka.connector.SnowflakeSinkConnec
浏览 3提问于2021-04-07得票数 0
2回答
type=sink, typeName='sink', location='file:path_to_kafka/kafka_2.12-2.3.0/libs/snowflakeinc-snowflake-kafka-connector/'}/path_to_kafka/
浏览 6提问于2019-12-13得票数 1
1回答
连接器任务状态无法连接
、、、
连接器的任务状态因错误而失败：
org.apache.kafka.connect.errors.ConnectException: java.lang.NoClassDefFoundError我在分布式模式下运行kafka连接集群，并使用kafka(0.10.0.2.5)连接的ambari部署。我使用导出CLASSPATH=/path给出了debezium mysql连接器路径。使用以下
浏览 0提问于2018-08-27得票数 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.Wor
浏览 31提问于2020-03-08得票数 1
我正在尝试创建一个连接器使用debezium连接器到postgresql和kafka连接。io.debezium.pipeline.ErrorHandler:31)
java.lang.RuntimeException: java.lang.BootstrapMethodError: java.lang.NoClassDefFoundErrorthrew an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.Wo
浏览 170提问于2021-01-01得票数 0
回答已采纳
我正在尝试为Kafka启动一个雪花连接器实例，遵循本教程：Kafka Version: 2.5.1snowflake.private.key=<private_key>snowflake.
浏览 2提问于2021-09-24得票数 1
回答已采纳
2回答
寻找关于我想要对主题中的消息进行处理的想法。我希望能够处理消息，在我的情况下，以10,000个为一批的事件。这是因为我在转换后将消息插入到我们的雪花仓库中。雪花加载在批处理加载时执行得更好。在主题中有10,000条消息之后才从主题中拉出消息的消费者有什么想法吗？IOW，一旦延迟达到10000，就从主题中拉出消息。有没有关于如何建立这样一个消费者的想法？
浏览 23提问于2019-08-08得票数 0
我正在尝试使用JDBC连接器将数据写入雪花，但我一直收到下面的错误，提示在数据库中找不到表(由于雪花不支持自动创建，所以我禁用了它)。Worker.run(ThreadPoolExecutor.java:628)我可以看到以下查询正在从雪花中的JDBC驱动程序中运行(并且直接在雪花中运行，在JDBC连接器中配置了相同的用户)确实返回数据。show /* JDBC:DatabaseMetaData.ge
浏览 1提问于2021-11-08得票数 2
1回答
正如标题所说，当从命令行启动ElasticSearch接收器连接器时，我得到了NoClassDefFoundError: io/confluent/connect/storage/StorageSinkConnectorConfig当我执行以下命令(或相对路径的任意组合)时，Zookeeper、Kafka broker和ElasticSearch都已启动并运行：
> C:\confluent-5.0.0\bin\windows\connect-standalone.batC:\
浏览 29提问于2018-09-05得票数 0
回答已采纳
1回答
根据的说法我们在SF2中有具有相同RECORD_METADATA的记录", "partition": 20,
"topic": "answe
浏览 1提问于2020-08-03得票数 0
当使用spark和snowflake连接时，我在我的日志中看到以下行： SnowflakeStrategy:下推失败: SQL编译错误 我查看了生成的SQL语句，其中显示了group by子句。而代码中的实际SQL语句没有显示任何group by语句。另外，我的代码在这一行没有失败。 为什么会有这条消息，是否真的会对输出产生一些影响？我没有看到我的输出受到影响！
浏览 11提问于2019-10-09得票数 2
我在独立模式下使用Elastic search Kafka连接。我并不困惑于使用哪种配置来启动Kafka，连接并从上一个故障点恢复。例如，生产者将继续将记录推送到Kafka和Consumer中，因为Elastic Search接收器连接器正在消耗，现在由于某种原因，我的消费者关闭了，但我的prouder仍将继续将消息推送到Kafka现在，当我修复了ES接收器连接器一侧的问题，如果我重启ES接收器连接器，它应该从最后一
浏览 20提问于2020-01-22得票数 0
回答已采纳
我们有几个阅读卡夫卡主题的flink应用程序，它们工作得很好。但最近，我们向现有的flink作业添加了一个新主题，它在启动时立即开始失败，并出现以下根错误：
Caused by: org.apache.kafka.common.KafkaException: java.lang.NoClassDefFoundError将lz4依赖项直接添加到应用程序中不起作用，奇怪的是，它在本地运行良好，但在远程集群上失败。flink运行时版本是1.9.1，我们在应用程序中有相同版本的
浏览 5提问于2020-07-31得票数 1
回答已采纳
我们需要找出为什么当我们尝试使用python的snowflake连接器通过lambda函数连接到snowflake时出现超时。我发现了一种在连接器中使用特定参数(insecure_mode)使其工作的不太安全的方法，如下所示： connection = snowflake.connector.connect(user=sf_usersf_database,schema=sf_schema,insecure_mode=True) 我们尝试使用insecu
浏览 24提问于2019-10-18得票数 0
2回答
我们在蒙古族有几个基于n个租户的集合，并且希望kafka连接器只监视特定的集合。下面是我的mongosource.properties文件，在这里我添加了管道过滤器，以便只侦听特定的collections.It工作。ca-tesla-cms-instance”,“ecom-tesla-cms-page”,“ca-tesla-cms-page”]}}}]
如果一个连接器监听大量的<
浏览 5提问于2022-05-12得票数 0
当我启动Confluent时，Schema-registry失败，阻止该过程成功完成。这是我得到的回应：zookeeper is [UP]kafka is [UP]1.: javax/xml/bind/ValidationException
有些错误会因位置的不同
浏览 14提问于2018-02-23得票数 1
回答已采纳
我正在构建一个自定义的Kafka源连接器。此连接器已启动并正在运行。我使用rest API更新连接器配置设置(例如，源端点和连接键)。我使用下面的Rest API PUT /connectors/{name}/config 由于某些问题(例如，错误的密钥)，API不会成功，连接器也会失败 接口输出如下所示。请注意，连接器处于failed状态，但任务仍在运行。事实上，它们仍然“连接”到旧的
浏览 33提问于2020-04-17得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
