如何将kafka连接到mysql？
我正在尝试将 kafka 与 windows 上的 mysql 连接起来。我没有使用汇合。我的 kafka 版本是 2.12 我已经启动了动物园管理员、Kafka、生产者和消费者，这一切都很好用。
我的MysQL版本是8.0.15
我已经在libs文件夹中复制了这3个jar文件
mysql-connector-java-8.0.15.jar
mysql-connector-java-5.1.47.jar
mysql-connector-java-5.1.47-bin.jar
我的源代码quickstart mysql。属性文件代码为
name=test-source-mysql-jdbc-autoincrement connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
tasks.max=1
connection.url=jdbc:mysql://localhost:3306/databasename?
user=rootname&password=password
mode=incrementing
incrementing.column.name=ID
topic.prefix=my-replicated-topic-table1
当我运行命令时
connect-standalone.bat ..\..\config\connect-standalone.properties ..\..\config\source-quickstart-mysql.properties
我在控制台上收到此错误
请帮助我。
我也试过这篇文章，但是没有用命令bin/confluent load JDBC-source-d JDBC-source . properties生成输出https://super gloo . com/Kafka-connect/Kafka-connect-MySQL-example/
共有3个答案
你可以在https://www . confluent . io/hub/Confluent Inc/Kafka-Connect-JDBC下载Kafka Connect JDBC，它是免费的，不需要Confluent平台。解压缩后，在已安装的Apache Kafka的config目录下的connect-standalone.properties中，更新key plugin.path的位置confluentinc-Kafka-connect-JDBC-5 . 5 . 1 . jar。再次运行脚本后，错误将消失。
如果在kafka lib路径中添加kafka-connect-jdbc-5.5.1.jar，重启kafka zookeeper和服务器。你应该能够连接。
您的错误是
org.apache.kafka.connect.errors.ConnectException: Failed to find any class that
implements Connector and which name matches io.confluent.connect.jdbc.JdbcSourceConnector
既然你说你没有使用Confluent平台，这是有道理的，因为kafka-connect-jdbc不是Apache Kafka的一部分。您可以使用 Confluent 平台、从源代码构建连接器，也可以在 http://hub.confluent.io 下载连接器。
-
下面是/etc/kafka/connect-MongoDB-source.properties中的MongoDB配置 但是低于误差 以独立模式运行连接器。 我在debezium-debezium-连接器-mongob-1.0.0/debezium-connector-mongodb-1.0.0.Final.jar 类路径的设置如下 使用插件路径，我看到它能够注册和加载所有必需的插件。 但最后还是同
-
问题内容： 我的Java程序出现这些错误。我已经把我的类路径放在里面了。如何解决呢？ 代码： 问题答案： 您需要从下载MySQL包：这里并将其放置在库中，我将修改在少数分钟excact步骤 这是连接数据库的正确语法： 希望这可以帮助
-
我正在尝试将node.js连接到MySQL，但失败了。我已经安装了MySQL和相关库。如何解决此错误？另外，如果我想让数据响应为原生的，我应该如何去做呢？ 收到的错误消息：
-
我目前正在做一个小项目，我需要将kafka集群连接到mongodb，以便将发布到kafka主题的消息存储在mongodb数据库中。我目前有一个本地kafka集群，一个sping引导生产者向一个主题发布消息，一个spinger引导消费者在本地使用这些消息。我也在本地安装了mongob指南针……我一直在看教程，我发现我必须使用某种接收器连接器（mongob连接器）来做我想做的事情，但大多数示例都是基于
-
我已经将 Kafka-connect-jdbc-5.5.0.jar 文件从 Confluent 下载到我的本地机器中，我想知道一种将此 jar 添加到 plugin.path=/kafka/connect 的方法。我正在尝试将数据接收器到 MySQL 服务器，所以我使用“连接器.class”：“io.confluent.connect.jdbc.JdbcSinkConnector”，但我面临“er
-
我在我的运行系统中有MongoDB和Robomongo，我使用Robomongo作为客户端。 我已将MongoDB安装在另一个系统上，我将其视为服务器，我想将我系统的Robomongo（作为客户端）连接到另一个系统（服务器）上的MongoDB。我应该采取哪些步骤来实现同样的目标？ 我使用的是机器名，因为系统的IP地址不是静态的。但即使我使用系统的IP地址，我也会遇到同样的错误： 连接失败，无法连接