SpringBoot Kafka Consumer：无法启动bean内部KafkaListener

Question

我有一个使用 kafka 的 spring boot 应用程序，但我无法启动它，因为我刚刚实现了一个正在监听离线服务器的 kafka 消费者。当我开始时我得到一些：org.springframework.context.ApplicationContextException：无法启动bean“org.springframework.kafka.config.internalKafkaListenerEndpointRegistry”；嵌套异常是 org.apache.kafka.common.errors.TimeoutException：获取主题元数据时超时已过期因为卡夫卡宕机了。如何配置 spring boot 应用程序，即使 kafka 服务器关闭也能启动？下面是我的 Kafka Consumer 配置：对于我的项目需求，我在 JAVA 中创建了一个 API，它接受如下 2 个参数getSimilarImages(@PathParam("rbcCode") String rbcCode, List<String> fieldNames)我是 POSTMAN 应用程序的新手。谁能教我如何使用 POSTMAN 调用此 API。下面是我的控制器文件代码。@Controller@Path("/services/AIMLServices")public class AIMLController {private static Logger LOG = LogManager.getLogger(AIMLController.class);@AutowiredAIMLService aimlService;@POST@Path("/getSimilarImages/{rbcCode}")@Produces(MediaType.APPLICATION_JSON)public String getSimilarImages(@PathParam("rbcCode") String rbcCode, List<String> fieldNames) {    LOG.info("IN getSimilarImages() API");    System.out.println("IN getSimilarImages() API rbcCode=" + rbcCode + " No of fields=" + fieldNames.size());    return aimlService.getSimilarImages(rbcCode, fieldNames).toString();}}我尝试在 POSTMAN 中进行以下设置，Doing a post call with the below URL by passing rbcCodehttp://localhost:4990/dev/acs/admin/fm/api/services/AIMLServices/getSimilarImages/BELKAnd under Body raw type as JSON, I am passing list like below["a","b","c"]但它不起作用。

Answer 1

在最新版本中，missingTopicsFatal容器属性为true，这就是导致此问题的原因。你可以把它关掉...

@Component

class ContainerFactoryConfigurer {

    ContainerFactoryConfigurer(ConcurrentKafkaListenerContainerFactory<?, ?> factory) {

        factory.getContainerProperties().setMissingTopicsFatal(false);

    }

}