Kafka Connect 添加 MySqlConnector 失败
Kafka Connect failed to add MySqlConnector
我需要别人的帮助。
我遵循教程 Streaming Data from MySQL into Kafka with Kafka Connect and Debezium 但我无法使用 Debezium MySQL 连接器将 MySql 连接到 Kafka 服务器。
这是我的设置和其他信息。
OS : Windows 10.
卡夫卡连接：Confluent 5.0。
MySQL 连接器：0.8.1 Final。
我保存文件
.
我添加插件路径
当我尝试连接到 Kafka Connect 时，它返回了一个错误。
"Failed to find any class that implements Connector and which name matches io.debezium.connector.mysql.MySqlConnector"
我错过了什么吗？有人可以帮忙吗？
确保您已将 .jar 连接器文件放在 plugins.path 下，该文件在 kafka-connect 属性中定义并且通常映射到 /usr/share/java.
在正确的目录下添加连接器后，您需要加载连接器或重新启动kafka-connect，以便它在启动时自动加载。
你的插件路径错误(confluent-5.0.0\share\java)
它应该以 / 开头（这意味着当前驱动器的根）或者你应该给出完整的路径。
这就是类路径中不存在连接器 jar 的原因
我需要别人的帮助。
我遵循教程 Streaming Data from MySQL into Kafka with Kafka Connect and Debezium 但我无法使用 Debezium MySQL 连接器将 MySql 连接到 Kafka 服务器。
这是我的设置和其他信息。
OS : Windows 10.
卡夫卡连接：Confluent 5.0。
MySQL 连接器：0.8.1 Final。
我保存文件
我添加插件路径
当我尝试连接到 Kafka Connect 时，它返回了一个错误。 "Failed to find any class that implements Connector and which name matches io.debezium.connector.mysql.MySqlConnector"
我错过了什么吗？有人可以帮忙吗？
确保您已将 .jar 连接器文件放在 plugins.path 下，该文件在 kafka-connect 属性中定义并且通常映射到 /usr/share/java.
在正确的目录下添加连接器后，您需要加载连接器或重新启动kafka-connect，以便它在启动时自动加载。
你的插件路径错误(confluent-5.0.0\share\java) 它应该以 / 开头（这意味着当前驱动器的根）或者你应该给出完整的路径。
这就是类路径中不存在连接器 jar 的原因