Kafka Streams 集成测试 - 由于类包不匹配而无法编译

Question

我正在尝试为 Confluent GitHub 中的集成测试类编译代码 - GenericAvroIntegrationTest.java对于当前存在于import org.apache.kafka.common.security.auth.SecurityProtocol;. 当我使用 maven 编译时，它抱怨说以下内容：[105,82] cannot access org.apache.kafka.common.protocol.SecurityProtocolclass file for org.apache.kafka.common.protocol.SecurityProtocol not found这在KafkaEmbedded.java类中使用。Confluent GitHub 上的代码使用该org.apache.kafka.common.protocol.SecurityProtocol包，但我使用的版本将相同的类移至我提到的另一个包：import org.apache.kafka.common.security.auth.SecurityProtocol. 如果我恢复到 Confluent 正在使用的版本，我的代码可能无法工作（不确定我错的是哪个依赖版本！:( ）。我如何解决这个冲突？我如何找到它被错误引用的地方？

Answer 1

如果你看一下 POM，你会看到

 <kafka.version>0.10.0.0-cp1</kafka.version>
 <confluent.version>3.0.0</confluent.version>

不确定这是否对您有帮助，因为您没有提到您使用的是哪个版本，但该代码不是具有最新代码的 Confluent Github。

试试https://github.com/confluentinc/kafka-streams-examples/blob/5.0.0-post/src/test/java/io/confluent/examples/streams/GenericAvroIntegrationTest.java