пакет kafka.producer не существует после перехода на kafka_2.11 - PullRequest
Новая
       5

пакет kafka.producer не существует после перехода на kafka_2.11

0 голосов
/ 06 ноября 2019

Я перешел на версию Kafka с 2.10 до 2.11 в файле pom, теперь я получаю ошибку ниже

изменения в pom с 

<dependency>
<groupId>org.apache.kafka</groupId> . 
<artifactId>kafka_2.10</artifactId>
<version>0.9.0-kafka-2.0.1</version>
<scope>compile</scope>
</dependency>

на 

<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.11</artifactId>
<version>2.1.0-cdh6.2.0</version>
<scope>compile</scope>
</dependency>

[ОШИБКА] Не удалось выполнить цель org.apache.maven.plugins: maven-compiler-plugin: 3.8.1: compile (default-compile) для проекта

пакет kafka.producer не существует

1 Ответ

0 голосов
/ 06 ноября 2019

Клиенты scala (частью которых являлась kafka.producer) годами устарели и были удалены.

Если вы намереваетесь модернизировать свой код, вы должны изменить свою зависимость на kafka-clients и изменить ее, чтобы использовать java.

Имейте в виду, что между "живыми" миграционными путями нет хорошегопотребители scala (которые хранят смещения в ZK) и более новые потребители java (которые хранят смещения в kafka) - подробности см. KIP-125

...