java - 嵌入式 Spring Kafka 尝试启动运行时 Kafka

Question

我有一个 Spring Kafka 项目，我已经为其编写了一些单元测试。 当我执行测试类时，项目尝试使用实际的 Kafka 代理，而不是我的测试类中注释的嵌入式 Kafka 代理。

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

我所尝试的内容已 checkin gitlab --> https://gitlab.com/mohammad.mnajar/spring-kafka-unit-test

任何帮助将不胜感激。

Answer 1

参见the documentation .

您需要将 spring.kafka.bootstrap-servers 属性设置为嵌入的 kafka 的 getBrokersAsString()。