java - 如果应用程序包含@KafkaListener注释，SpringBootTest会失败

Question

我通过简单的测试创建了一个新的 Spring Boot 项目:

@RunWith(SpringRunner.class)
@SpringBootTest
public class ExampleApplicationTests {

    @Test
    public void contextLoads() {
    }

}

当我运行此测试时，它成功了。但是如果我向任何服务添加任何带有 @KafkaListener 注释的方法:

@KafkaListener(topics = "test", groupId = "v-group")
public void test(){
  log.info("test");
}

并运行测试，它有时会起作用并引发异常:

Caused by: org.springframework.context.ApplicationContextException: Failed to start bean 'org.springframework.kafka.config.internalKafkaListenerEndpointRegistry'; nested exception is org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata

Answer 1

默认情况下，当应用程序上下文加载时，框架将为监听器start()监听器容器。

您可以将 autoStartup 属性设置为 false 以阻止容器启动。

@KafkaListener(topics = "test", groupId = "v-group", autoStartup = "false")
public void test(){
  log.info("test");
}