更改为 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 详情
我在 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 详情