包kafka.producer更改为kafka_2.11后不存在

Question

我已将pom文件中的Kafka版本从2.10更改为2.11，现在出现以下错误

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>

to

<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不存在

Answer 1

scala客户程序（kafka.producer的一部分）已被淘汰多年，并且已被删除。

如果您打算现代化代码，则应将依赖项更改为kafka-clients并重构为使用Java的依赖项。

[请注意，scala使用者（将偏移量存储在ZK中）和较新的Java使用者（将偏移量存储在kafka中）之间没有良好的“实时”迁移路径-有关详细信息，请参见KIP-125