卡夫卡连接未能添加MySqlConnector

Question

我需要别人的帮助。

我遵循用卡夫卡连接和Debezium将数据从MySQL流到卡夫卡教程，但是我很难使用Debezium MySql连接器将MySQL连接到卡夫卡服务器。

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

操作系统: Windows 10。

卡夫卡连接：汇合5.0。

MySQL连接器: 0.8.1决赛。

我有档案

​

。

我添加插件路径

​

​

​

​

当我试图连接到Kafka Connect时，它给了我一个错误。“未能找到实现连接器且名称与io.debezium.connector.mysql.MySqlConnector匹配的任何类”

​

​

​

我是不是遗漏了什么？有人能帮忙吗？

Answer 1

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

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

Answer 2

您的插件路径是错误的(合-5.0.0\share\java)，要么它应该以/(这意味着当前驱动器的根)开始，要么您应该给出完整的路径。

这就是为什么类路径中不存在连接器jar的原因。