更改为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(默认编译)

软件包kafka.producer不存在

xiaovin 回答:更改为kafka_2.11

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

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

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

本文链接:https://www.f2er.com/3156434.html

大家都在问