kafka:无法使用mapr clients“java.lang.compatibleClassChangeError:implementing class”运行kafka connect hdfs sink2

tcbh2hod  于 2021-07-15  发布在  Kafka
关注(0)|答案(0)|浏览(185)

我下载了Confluent5.4.2版本和Sink2连接器(5.4.2)。我使用的是mapr版本的6.1.0,jar包含在类路径中。我注意到kafka connect hdfs有hadoop版本2.7.3,但我得到一个错误:

[2021-04-26 16:23:29,091] ERROR Stopping due to error (org.apache.kafka.connect.cli.ConnectDistributed:84)
java.lang.IncompatibleClassChangeError: Implementing class

这是因为hadoop版本冲突吗?如果是,我怎么知道是哪一个?以下是kafka connect hdfs包中包含的hadoop jar:

hadoop-annotations-2.7.3.jar                 hadoop-mapreduce-client-shuffle-2.7.3.jar
hadoop-client-2.7.3.jar                      hadoop-yarn-api-2.7.3.jar
hadoop-common-2.7.3.jar                      hadoop-yarn-client-2.7.3.jar
hadoop-hdfs-2.7.3.jar                        hadoop-yarn-common-2.7.3.jar
hadoop-mapreduce-client-app-2.7.3.jar        hadoop-yarn-server-applicationhistoryservice-2.6.0.jar
hadoop-mapreduce-client-common-2.7.3.jar     hadoop-yarn-server-common-2.7.3.jar
hadoop-mapreduce-client-core-2.7.3.jar       hadoop-yarn-server-resourcemanager-2.7.3.jar
hadoop-mapreduce-client-jobclient-2.7.3.jar  hadoop-yarn-server-web-proxy-2.6.0.jar

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题