java - 嵌入式 Spring Kafka 尝试启动运行时 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属性设置为嵌入式 kafka 的getBrokersAsString().