我下载了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
暂无答案!
目前还没有任何答案,快来回答吧!