Встроенная Spring Kafka пытается запустить Runtime Kafka

Question

У меня есть проект Spring Kafka, и я написал для него несколько модульных тестов. Когда я выполняю тестовые классы, проект пытается использовать реального брокера Kafka, а не встроенного брокера Kafka, как указано в моем тестовом классе.

@RunWith(SpringRunner.class)
@SpringBootTest
@EmbeddedKafka
@DirtiesContext
public class SpringKafkaReceiverTest {...}

То, что я пытался сделать, проверено на gitlab -> https://gitlab.com/mohammad.mnajar/spring-kafka-unit-test

Любая помощь будет чрезвычайно признательна.

Answer 1

См. документацию .

Вам необходимо установить свойство spring.kafka.bootstrap-servers для встроенного кафки getBrokersAsString().