3

我需要别人的帮助。

我按照教程使用 Kafka Connect 和 Debezium 将数据从 MySQL 流式传输到 Kafka，但是我在使用 Debezium MySQL 连接器将 MySql 连接到 Kafka 服务器时遇到了麻烦。

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

操作系统：Windows 10。

卡夫卡连接：汇合 5.0。

MySQL 连接器：0.8.1 最终版。

我保存文件

这里.

我添加插件路径

图片1

图二

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

错误 1

错误 2

我错过了什么吗？任何人都可以帮忙吗？

4

2 回答 2

2

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

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

于 2018-08-14T08:19:06.390 回答
0

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

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

于 2018-08-21T11:36:00.380 回答