Как мне создать сборщик коннектора hdfs kafka с новой версией Hadoop? - PullRequest
1 голос
/ 14 мая 2019

Мы используем Azure DataLake Storage 2. Файл .jar, чтобы обеспечить его работу, требует hadoop-common-3.1.1.3.jar, тогда как Confluent-коннектор поставляется только с 2.7.6 Hadoop (и, следовательно, hadoop-common-2.7.6.jar).

Как мы будем строить новую версию?

Попытался отредактировать pom.xml и изменил Hadoop на 3.1.1.3, но он не может собрать

<properties>
        <confluent.maven.repo>http://packages.confluent.io/maven/</confluent.maven.repo>
        <hadoop.version>3.1.1</hadoop.version>
        <apacheds-jdbm1.version>2.0.0-M2</apacheds-jdbm1.version>
        <kafka.connect.maven.plugin.version>0.11.2</kafka.connect.maven.plugin.version>
</properties>

Если я внесу это изменение выше, то при установке mvn произойдет следующая ошибка

ERROR] Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.8.0:compile (default-compile) on project kafka-connect-hdfs: Compilation failure
ERROR] /C:/*****/GitHub/kafka-connect-hdfs/src/main/java/io/confluent/connect/hdfs/wal/WALFile.java:[327,5] method does not override or implement a method from a supertype
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...