kafka-connect-jdbc源连接器OOM

文章/答案/技术大牛

发布

1回答

docker、jdbc、apache-kafka、apache-kafka-connect、confluent-platform

我使用的是kafka-connect-jdbc:5.3.1，当我运行连接器时，它会将我踢出系统，出现异常：java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandlervalidate.non.null=falsetopic.prefix=kafka02- poll.interval.ms=3600 我通过EC2上的Docker容器运行这个连接器

浏览 16提问于2019-09-13得票数 0

回答已采纳

1回答

kafka-connect jdbc分布式模式

apache-kafka、apache-kafka-connect、confluent-platform

我们正在使用increment+timestamp模式下的JDBC源连接器构建Kafka-connect应用程序。我们尝试了独立模式，它可以像预期的那样工作。现在，我们想切换到分布式模式。当我们有一个单一的Hive表作为源时，任务将如何在工作人员之间分配？我们面临的问题是，当我们在多个实例中运行应用程序时，它会查询每个实例的表，并再次获取相同的行。并行在这种情况下会起作用吗？

浏览 4提问于2018-08-29得票数 0

1回答

如何使用jdbc连接器将ksql表数据导出到Mysql表

mysql、apache-kafka、confluent-platform、connector、ksqldb

有没有办法通过jdbc连接器将数据从KSQL导出到mysql表中？？我了解了如何使用KSQL将mysql表数据导入到Kafka集群中。但这不是我想要的。host --interactive --tty \ confluentinc/cp-ksql-cli:5.3.1 https://www.confluent.io/hub/confluentinc/kafka-connect-jdbc

浏览 44提问于2020-03-17得票数 0

1回答

kafka jdbc接收器连接器独立错误

jdbc、apache-kafka-connect、confluent-platform

/bin/connect-standalone etc/schema-registry/connect-avro-standalone.properties etc/kafka-connect-jdbctrue[2019-01-29 13:16:48,859] ERROR Failed to create job for /home/ashley/confluent-5.1.0/etc/kafka-connect-jdbc

浏览 0提问于2019-01-29得票数 0

1回答

与汇合连接器

apache-kafka、apache-kafka-connect、confluent-platform

使用与融合Kafka有什么区别？

浏览 6提问于2020-09-28得票数 0

4回答

Kafka-Connect将SQL JAR文件添加到类路径

java、apache-kafka、apache-kafka-connect

我正在尝试部署一个独立的连接作业来从mssql服务器流传输，但是我遇到了一个问题(Kafka-Connect是我的Ambari部署的一部分，而不是docker)。这是我正在使用的属性文件：connector.class=io.confluent.connect.jdbc.JdbcSourceConnectorconnection.password=pwconnection.url=jdbc:sqlserver://servernamequ

浏览 1提问于2018-05-29得票数 1

1回答

无法连接到SQLServer卡夫卡连接

sql-server、docker、jdbc、apache-kafka、apache-kafka-connect

我尝试添加一个JDBC连接器，以插入Kafka主题，但是我得到了这个错误。

浏览 0提问于2018-05-24得票数 1

回答已采纳

1回答

连接器列表不显示已安装的连接器。

apache-kafka、apache-kafka-connect、confluent-platform

日安，confluent-hub install confluentinc/kafka-connect-jdbc:latest之后，我按照下一条指令将jdbc驱动程序jar文件上传到share/java/kafka-connect-jdbc。 confluent lo

浏览 4提问于2022-03-11得票数 0

1回答

如何执行JDBC Kafka Connector jar

jdbc、apache-kafka、apache-kafka-connect

我克隆了，但我在理解如何执行它时遇到了问题。

浏览 2提问于2018-05-11得票数 0

1回答

即使安装了JdbcSinkConnector，Kafka connect也无法找到它

apache-kafka、apache-kafka-connect、confluent-platform

我已经在我的kafka connect连接器中安装了运行confluent-hub install --no-prompt confluentinc/kafka-connect-jdbc:10.2.5的JDBC连接器，但是当我尝试使用实现一个新的接收器时，我遇到了以下错误:找不到任何实现连接器并且名称与io.confluent.connect.jdbc.JdbcSinkConnector匹配的类} 我使用的是confluentinc/cp-kafka-connect:6.1.0

浏览 7提问于2021-10-30得票数 0

1回答

Windows上的Kafka Connect for Oracle安装程序

apache-kafka、windows-7、apache-kafka-connect

我可以在我的windows7机器上设置Kafka服务器/zookeeper。创建了一个.NET应用程序来生产和使用应用程序。我现在需要oracle来使用生成的主题。我需要一些关于在我的运行在Windows 7上的Kafka上设置Kafka连接的说明。请给我一些如何做到这一点的指导。我对卡夫卡非常陌生。到目前为止，我所做的只是在windows上设置Kafka服务器。

浏览 26提问于2019-06-07得票数 0

回答已采纳

3回答

kafka-connect: SQLException:只有在使用分布式模式时，才没有合适的驱动程序。

mysql、jdbc、apache-kafka、apache-kafka-connect、confluent-platform

我们已经成功地使用了使用jdbc独立连接器的mySQL - kafka数据吞并，但是在分布式模式下(作为kafka连接服务)，我们现在面临着同样的问题。status.storage.replication.factor=2plugin.path=/usr/share/java,/usr/share/java/kafka-connect-jdbc我的连接器瓶在这里- /usr/share&#

浏览 2提问于2018-11-15得票数 0

回答已采纳

1回答

Kafka Connect JDBC源即使查询失败也能运行

jdbc、apache-kafka、apache-kafka-connect、confluent-platform

我正在运行一个JDBC源连接器，并尝试通过公开的JMX指标和prometheus导出器以某种方式监视其状态。但是，当查询失败或无法访问db时，连接器及其所有任务的状态仍处于运行状态。在早期版本中，当查询失败时，源任务指标中的source-record-poll-total值似乎没有导出，在我使用的版本(connect-runtime-6.2.0-ccs，confluentinc-kafka-connect-jdbc

浏览 17提问于2021-06-23得票数 0

回答已采纳

2回答

将数据从kafka复制到mysql，不能用DOcker和Debezium连接到DOcker。

mysql、apache-kafka-connect、debezium

(9.4.18.v20190429) {“io.confluent.connect.jdbc.JdbcSinkConnector，error_code”：500，“message”：“未能找到任何实现连接器且名称与io.debezium.connector.mongodb.MongoDbConnector，name='io.debezium.connector.mongodb.MongoDbConnector'，可用连接器匹配的类org.apache.kafka.connect.tools.MockConnector，PluginDesc

浏览 0提问于2019-11-06得票数 0

1回答

kafka连接文件脉冲连接器无法独立启动(在偏移管理器上找不到类异常)

apache-kafka、apache-kafka-connect

我想使用filepulse连接器将xml文件加载到kafka。下面是我尝试过的jdbc连接器，只是为了看看其他连接器是否正常工作。是的，，而不是，有例外。connect-standalone \/home/min/confluent-5.5.1/etc/kafka-connect-jdbcstreamthoughts-kafka-connect-file-pulse-1

浏览 5提问于2020-09-08得票数 0

2回答

Kafka JDBC连接器-尝试将AvroConverter架构注册表详细信息作为新列添加到目标表中

apache-kafka、kafka-consumer-api、apache-kafka-connect

集群中的数据已使用AvroConverter加载，模式详细信息还包含源、op、ts_ms等字段。value我将把连接器的详细信息放在下面FROM confluentinc/cp-kafka-connect-base:latest RUN confluent-hub install --no-prompt confluentinc/kafka

浏览 16提问于2022-04-10得票数 1

回答已采纳

1回答

向Kafka连接中添加连接器

jar、apache-kafka、apache-kafka-connect

我使用的是合流卡夫卡码头形象，特别是使用这个：用下载的连接器(mysql-连接器-java-5.1.46-bin.jar但是，当然，如果我尝试使用连接器，我在启用连接器的列表中找不到。

浏览 0提问于2018-03-18得票数 3

回答已采纳

1回答

Debezium oracle on confluent找不到适用于jdbc的驱动程序:oracle:oci

oracle、apache-kafka、apache-kafka-connect、debezium

当我创建kafka jdbc源连接器(用于oracle的debezium连接器，使用confluent-5.4.0)时，收到错误消息“没有找到适用于jdbc的驱动程序:oracle:oci...”。正如Debezium文档所说，我安装了即时客户端，并将文件_ojbc8.jar和xtreams.jar从即时客户端复制到Kafka的库中[root

浏览 3提问于2020-03-23得票数 1

1回答

如何在DC/OS上将JDBC驱动程序添加到Kafka Connect中？

docker、apache-kafka、mesos、apache-kafka-connect、dcos

使用合流社区包在DC/OS上运行Kafka 4.1.1。我们如何上传或添加jdbc驱动程序到远程集群？

浏览 1提问于2018-11-11得票数 1

1回答

kafka能否通过融合平台使用JDBC连接器interclient.jar与interbase连接？

jdbc、apache-kafka、apache-kafka-connect、confluent-platform、interbase

这是我用来创建连接器的POST命令。我已经在/usr/share/java/kafka-connect-jdbc中放置了JDBC连接器interclient.jar文件。我也有KAFKA_CONNECT_JARS_PATH=/usr/share/java/kafka-connect-jdbc/和CLASS_PATH=usr/share/java/kafka-connect-jdbc

浏览 0提问于2018-12-12得票数 0

点击加载更多