如何将kafka-connect-jdbc-5.5.0.jar添加到Debezium/连接
我已经将 Kafka-connect-jdbc-5.5.0.jar 文件从 Confluent 下载到我的本地机器中，我想知道一种将此 jar 添加到 plugin.path=/kafka/connect 的方法。我正在尝试将数据接收器到 MySQL 服务器，所以我使用“连接器.class”：“io.confluent.connect.jdbc.JdbcSinkConnector”，但我面临“error_code”：500，“消息”：“找不到任何实现连接器的类以及哪个名称与 io.confluent.connect.jdbc.JdbcSinkConnector 匹配，我在 Windows 机器中使用 docker 工具箱
共有1个答案
请检查这份样本档案。它演示了如何为JDBC和Elasticsearch部署接收器连接器。通常，要记住的最重要的一点是，如果< code>plagin.path被设置为< code>/kafka/connect,那么连接器将被显示在名为< code>/kafka/connect/的目录中
-
问题内容： JDBC连接器和Debezium SQL Server CDC连接器（或任何其他关系数据库连接器）之间有什么区别？何时应该选择一个 ，寻找一种在两个关系数据库之间进行同步的解决方案？ 不确定此讨论是否应该针对CDC与JDBC连接器，而不是 Debezium SQL Server CDC连接器，甚至不是Debezium，期待 以后进行编辑，取决于给出的答案（尽管我的情况是关于SQL Se
-
我有一个Debezium连接器，连接到SQL服务器，其中一个表在配置参数中。我想添加另一个表，我已经添加到参数中，尽管我的连接器没有接收到它。 我以前的看起来像这样： 我当前的如下所示： 我重启了Kafka，重启了Debezium中的连接器，但是当我查看bash中的连接器状态时，我仍然看到旧的值。是否需要做其他事情来让连接器刷新配置文件中的内容？ Debezium版本：1.2.5。Kafka最终版
-
向Postgres连接器中添加新表的步骤应该是什么？我的连接器正在跟踪两个表（表1和表2），我想添加另一个表（表3），它已经存在，并且在我的数据库中有数据。 这是我当前的配置： } 我试图修改连接器“table.include.list”并将“public.table3”添加到列表中，但它似乎没有触发此表的快照过程。 有什么想法吗？
-
我有一个Kafka Connect集群，它有JDBC源连接器插件。我也有自己的定制SMT，它是一个jar文件，可以使用JDBC源连接器插件来处理我的用例，例如my-custom-1.0.0.jar。例如以下内容。变压器类型是我自己的java类MySMT 我知道我可以将jar文件放在plugin.path中。然而，是否可以重新加载连接器插件（JDBC源连接器）来加载我的SMT jar，而不重新启动K
-
我正在使用Confluent Kafka Docker镜像，特别是使用这个： https://github.com/confluentinc/cp-docker-images/tree/4.0.x/examples/cp-all-in-one 我想添加MySQL连接器，通过： 正在下载连接器的1.5.46版本（https://dev.mysql.com/get/Downloads/Connecto
-
我正在尝试使用JDBC通过kafka connect访问SAP Advantage DB。我正在使用docker容器，并且我已经添加了来自http://devzone.advantagedatabase.com/dz/content.aspx?Key=20的jdbc驱动程序Jar 当我尝试使用它时，我收到一个错误的 URL 错误