我尝试使用嵌入式kafka进行测试,我使用spring boot和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() {
....
}但是,我的No resolvable bootstrap urls given in bootstrap servers测试失败了
我也在使用一个测试配置文件,在yml文件中我已经
bootstrap-servers :{spring.embedded.kafka.brokers}请帮帮忙。
发布于 2020-01-31 00:09:29
@SpringBootTest在创建测试类实例和初始化成员字段之前初始化测试Spring Boot应用程序上下文。因此,当字段稍后初始化时,@SpringBootApplication看不到EmbeddedKafkaBroker。
尝试关注a working example from this answer
@SpringBootTest
@EnableKafka
@EmbeddedKafka(
partitions = 1,
controlledShutdown = false,
brokerProperties = {
"listeners=PLAINTEXT://localhost:3333",
"port=3333"
})
public class KafkaConsumerTest {
@Autowired
KafkaEmbedded kafkaEmbeded;
}https://stackoverflow.com/questions/59989897
复制相似问题