kafka报错Failed to find any class that implements Connector

在使用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相关推荐

【Flink】Flink 写入 kafka 报错 Failed to send data to Kafka: Expiring 4 record(s) for 20001 ms has passed
文章目录 1.场景1 1.1 概述 1.2 百度 1.3 同样问题 2.场景再现本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载. 1.场景1 1.1 概 ...
【Flink】flink Kafka报错 : Failed to send data to Kafka: This server is not the leader for that topic-pa
1.背景出现这个问题的背景请参考:[Kafka]Failed to send data to Kafka: Expiring 30 record(s) for xxx 732453 ms has p ...
【Kafka】Flink kafka 报错 Failed to send data to Kafka: Failed to allocate memory within the config
1.背景 [2020-09-05 14:57:51] [INFO] [org.apache.flink
【Kafka】kafka报错 UnknownHostException: %HOSTGROUP::host_group_zookeeper%: Temporary failure in name re
1.概述背景和这个有关:[Kafka]docker下kafka报错 IOException: Connection to xxx:19093 (id: 1002 rack: null) failed ...
Flink读取Kafka报错：KafkaException ByteArrayDeserializer is not an instance Deserializer
1.视界 2.背景做flink读取kafka报错 org.apache.kafka.common.KafkaException: Failed to construct kafka consumer ...
win10 启动kafka报错另一个程序正在使用此文件，进程无法访问
welcome to my blog 问题描述: win10启动kafka报错: ERROR Failed to clean up log for __consumer_offsets-39 in d ...
Pyinstaller 打包exe 报错 “failed to execute script XXX“的一种解决方案
Pyinstaller 打包exe 报错 "failed to execute script XXX"的一种解决方案参考文章: (1)Pyinstaller 打包exe 报错 & ...
tomcat运行报错Failed to start component [StandardEngine[Catalina].StandardHost[localhost].
一.问题 tomcat运行报错Failed to start component [StandardEngine[Catalina].StandardHost[localhost]. 多半情况是找不到 ...
kafka 报错：kafka server：Message was too large ，server rejected it to avoid allocation
kafka报错信息: kafka server:Message was too large ,server rejected it to avoid allocation kafka版本: kafk ...

kafka报错Failed to find any class that implements Connector

kafka报错Failed to find any class that implements Connector相关推荐

最新文章

热门文章