apache-kafka - Kafka Connect 添加 MySqlConnector 失败

Question

我需要别人的帮助。

我遵循教程 Streaming Data from MySQL into Kafka with Kafka Connect and Debezium但我无法使用 Debezium MySQL Connector 将 MySql 连接到 Kafka 服务器。

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

操作系统:Windows 10。

卡夫卡连接:Confluent 5.0 .

MySQL 连接器:0.8.1 最终版本。

我保存文件

.

我添加插件路径

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

我错过了什么吗？谁能帮忙？

Answer 1

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

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