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

package kafka.producer does not exist after changing to kafka_2.11

我在 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>

<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) on project

包kafka.producer不存在

scala 客户端(kafka.producer 是其中的一部分)已被弃用多年并已被删除。

如果您打算使您的代码现代化,您应该将您的依赖项更改为 kafka-clients 并重构它以使用 java 个。

请注意,scala 消费者(在 ZK 中存储偏移量)和较新的 java 消费者(在 kafka 中存储偏移量)之间没有好的 "live" 迁移路径 - 参见 KIP-125 详情