Kafka Connect 未能添加 MySqlConnector答案

【问题标题】：Kafka Connect failed to add MySqlConnectorKafka Connect 未能添加 MySqlConnector
【发布时间】：2019-01-20 23:31:55
【问题描述】：

我需要别人的帮助。

我按照教程 Streaming Data from MySQL into Kafka with Kafka Connect and Debezium 进行操作，但我无法使用 Debezium MySQL 连接器将 MySql 连接到 Kafka 服务器。

这是我的设置和其他信息。

操作系统：Windows 10。

卡夫卡连接：Confluent 5.0。

MySQL 连接器：0.8.1 最终版。

我保留文件

我添加插件路径

当我尝试连接到 Kafka Connect 时，它返回了一个错误。 "找不到任何实现 Connector 且名称与 io.debezium.connector.mysql.MySqlConnector 匹配的类"

我错过了什么吗？有人可以帮忙吗？

【问题讨论】：

如果您在 kafka-connect 已经启动并运行时添加了连接器，那么您需要手动加载连接器，或者重新启动 kafka-connect
@GiorgosMyrianthous 我已经重启了 kafka Connect 服务器，但结果还是一样。
你需要将jar文件放在kafka-connect属性中定义的plugins.path下，通常指向/usr/share/java
@GiorgosMyrianthous 我已将所有插件文件夹放在自定义路径中，并且我已经根据图 1 和图 2 在 kafka-connect 属性文件中添加了路径。
如我所说，只将jar文件放在/usr/share/java下。

【解决方案1】：

确保您已将 .jar 连接器文件放在 plugins.path 下，该文件在 kafka-connect 属性中定义，通常映射到 /usr/share/java。

在正确的目录下添加连接器后，您需要加载连接器或重新启动 kafka-connect 以便在启动时自动加载它。

【讨论】：

【解决方案2】：

您的插件路径错误 (confluent-5.0.0\share\java) 要么它应该以 / 开头（这意味着当前驱动器的根目录），要么你应该给出完整的路径。

这是连接器 jar 不存在于类路径中的原因

【讨论】：