Тестирование интеграции Kafka Streams - Невозможно скомпилировать из-за несоответствия пакетов классов - Apache Kafka, KafkaEmbedded

Question

Я пытаюсь скомпилировать код для классов интеграционных тестов, найденных в Confluent GitHub - GenericAvroIntegrationTest.java

Я получаю исключение времени компиляции для одного из классов SecurityProtocol, которыйв настоящее время присутствует в import org.apache.kafka.common.security.auth.SecurityProtocol;.Когда я компилирую с использованием maven, он жалуется, говоря следующее:

[105,82] cannot access org.apache.kafka.common.protocol.SecurityProtocol


class 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