在使用kafka的connect的功能時候遇到報錯.

完整報錯如下:

[2020-09-11 11:14:53,612] ERROR Failed to create job for /home/appleyuchi/bigdata/kafka_2.12-2.5.0-1/config/quickstart-mysql.properties (org.apache.kafka.connect.cli.ConnectStandalone:110)
[2020-09-11 11:14:53,613] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:121)
java.util.concurrent.ExecutionException: org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches io.confluent.connect.jdbc.JdbcSourceConnector, available connectors are: PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSinkConnector, name='org.apache.kafka.connect.file.FileStreamSinkConnector', version='2.5.0', encodedVersion=2.5.0, type=sink, typeName='sink', location='classpath'}, PluginDesc{klass=class?

?

所以報錯信息中重點是:

Failed to find any class that implements Connector and which name matches io.confluent.connect.jdbc.JdbcSourceConnector,

maven倉庫下載kafka-connect-jdbc-5.5.1.jar?mysql-connector-java-8.0.21.jar之后放入

$KAFKA/libs下面

即可

?

Reference:

[1]confluent-5.0.0: Failed to find any class that implements Connector and which name matches io.confluent.connect.jdbc .JdbcSourceConnector #476

?

總結

以上是生活随笔為你收集整理的kafka报错Failed to find any class that implements Connector的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。