Kafka Connect 添加 MySqlConnector 失败 [英] Kafka Connect failed to add MySqlConnector

问题描述

我需要别人的帮助.

我按照教程 使用 Kafka Connect 和 Debezium 将数据从 MySQL 流式传输到 Kafka，但我无法使用 Debezium MySQL Connector 将 MySql 连接到 Kafka 服务器.

I follow a tutorial Streaming Data from MySQL into Kafka with Kafka Connect and Debezium but I have the trouble connecting MySql to Kafka server using Debezium MySQL Connector.

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

Here is my setup and other information.

操作系统:Windows 10.

OS : Windows 10.

Kafka 连接:Confluent 5.0.

MySQL 连接器:0.8.1 最终版.

MySQL Connector : 0.8.1 Final.

我保存文件

.

我添加了插件路径

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

When I tried connecting to Kafka Connect, It returned me an error. "Failed to find any class that implements Connector and which name matches io.debezium.connector.mysql.MySqlConnector"

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

Am I missing something? Anyone can help?

推荐答案

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

Make sure that you've placed the .jar connector file under plugins.path which is defined in kafka-connect properties and usually maps to /usr/share/java.

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

After adding the connector under the correct directory you need to either load the connector or restart kafka-connect so that it is automatically loaded in start-up.

这篇关于Kafka Connect 添加 MySqlConnector 失败的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！