是什么原因导致了这个debezium-kafka连接器错误



我想连接mysql->debezium->kafka(合流云(。我想知道是否有人能帮我处理这个错误消息:

找不到任何实现连接器且名称与io.debezium.connecter.mysql.MySqlConnector.匹配的类

我的kafka工人文件中有debezium的jar文件:

plugin.path=/home/ec2 user/kafka/plugins-

插件文件夹的内容如下:

-antlr4-运行时间-4.7.2.jar

-debezium-api-1.5.3最终.jar

-debezium-connector-mysql-1.5.3.Final.jar

-debezium-core-1.5.3最终.jar

-debezium-ddl-parser-1.5.3 Final.jar

-失败访问-1.0.1.jar

-guava-30.0-jre.jar

-mysql-binlog-connector-java-0.25.1.jar

-mysql-connector-java-8.0.21.jar

当我启动分发服务器时,我看到添加了插件:

[2021-06-24 23:01:54,680] INFO Registered loader: PluginClassLoader{pluginLocation=file:/home/ec2-user/kafka/plugins/debezium-api-1.5.3.Final.jar}
[2021-06-24 23:01:54,684] INFO Loading plugin from: /home/ec2-user/kafka/plugins/debezium-connector-mysql-1.5.3.Final.jar
[2021-06-24 23:01:54,744] INFO Registered loader: PluginClassLoader{pluginLocation=file:/home/ec2-user/kafka/plugins/debezium-connector-mysql-
[2021-06-24 23:01:54,745] INFO Added plugin 'io.debezium.connector.mysql.transforms.ReadToInsertEvent'
[2021-06-24 23:01:54,745] INFO Loading plugin from: /home/ec2-user/kafka/plugins/debezium-core-1.5.3.Final.jar
[2021-06-24 23:01:54,866] INFO Registered loader: PluginClassLoader{pluginLocation=file:/home/ec2-user/kafka/plugins/debezium-core-1.5.3.Final.jar} 
[2021-06-24 23:01:54,867] INFO Added plugin 'io.debezium.converters.CloudEventsConverter'
[2021-06-24 23:01:54,871] INFO Added plugin 'io.debezium.transforms.outbox.EventRouter'
[2021-06-24 23:01:54,872] INFO Added plugin 'io.debezium.transforms.ExtractNewRecordState'
[2021-06-24 23:01:54,872] INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter'
[2021-06-24 23:01:54,873] INFO Added plugin 'io.debezium.transforms.tracing.ActivateTracingSpan'
[2021-06-24 23:01:54,873] INFO Loading plugin from: /home/ec2-user/kafka/plugins/debezium-ddl-parser-1.5.3.Final.jar
[2021-06-24 23:01:55,060] INFO Registered loader: PluginClassLoader{pluginLocation=file:/home/ec2-user/kafka/plugins/debezium-ddl-parser-1.5.3.Final.jar}
[2021-06-24 23:01:55,061] INFO Loading plugin from: /home/ec2-user/kafka/plugins/failureaccess-1.0.1.jar
[2021-06-24 23:01:55,069] INFO Registered loader: PluginClassLoader{pluginLocation=file:/home/ec2-user/kafka/plugins/failureaccess-1.0.1.jar}
[2021-06-24 23:01:55,070] INFO Loading plugin from: /home/ec2-user/kafka/plugins/guava-30.0-jre.jar
[2021-06-24 23:01:55,307] INFO Registered loader: PluginClassLoader{pluginLocation=file:/home/ec2-user/kafka/plugins/guava-30.0-jre.jar}

然而,当我运行curl命令时:

curl-s-X POST-H‘内容类型:application/json’--数据@debe-connector.jsonhttp://localhost:8083/connectors-v

我得到错误:

找不到任何实现连接器且名称与io.debezium.connecter.mysql.MySqlConnector.匹配的类

知道我可能缺少什么吗?

谢谢,

您需要将debezium mysql connector的所有jar文件放在目录中

/home/ec2-user/kafka/plugins/debezium-connector-mysql

而不是低于

/home/ec2-user/kafka/plugins

您可以使用curl命令

curl -X GET http://localhost:8083/connector-plugins

查看哪些插件安装正确。如果此处未列出debezium,则表示安装存在问题。您可能需要检查文件权限。

最新更新