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.

OS:Windows 10.

OS : Windows 10.

Kafka Connect: Confluent 5.0 .

Kafka Connect : Confluent 5.0.

MySQL Connector:0.8.1最终版.

MySQL Connector : 0.8.1 Final.

我保留文件

.

我添加了插件路径

当我尝试连接到Kafka Connect时，它返回了一个错误. 找不到任何实现Connector且名称与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连接器文件放置在下，该文件在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屋！