Spring嵌入式kafka with Junit5-在引导服务器中没有可解析的引导URL

Question

我正在尝试使用嵌入式kafka进行我的测试。我使用Spring引导和Junit5，如下所示

@SpringBootTest
@EmbeddedKafka
public class MyTest {
//Instead of the class rule approach I'm using
EmbeddedKafkaBroker embeddedKafka = new EmbeddedKafkaBroker(1,true,topics);
..
@Test
public void myTestCase() {
....

}

然而，我的测试失败了，因为引导服务器中没有给出可解析的引导URL

我也在使用一个测试配置文件，在yml文件中

 bootstrap-servers :{spring.embedded.kafka.brokers}

请帮忙。

Answer 1

在创建测试类实例和初始化成员字段之前，SpringBootTest初始化测试Spring启动应用程序上下文。由于该字段稍后初始化，因此SpringBootApplication无法看到嵌入的Kafkabroker。

尝试以下回答中的一个有效示例：

@SpringBootTest
@EnableKafka
@EmbeddedKafka(
    partitions = 1, 
    controlledShutdown = false,
    brokerProperties = {
        "listeners=PLAINTEXT://localhost:3333", 
        "port=3333"
})
public class KafkaConsumerTest {
    @Autowired
    KafkaEmbedded kafkaEmbeded;
}