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);

@Autowired

AIMLService 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 rbcCode

http://localhost:4990/dev/acs/admin/fm/api/services/AIMLServices/getSimilarImages/BELK

And under Body raw type as JSON, I am passing list like below

["a","b","c"]

但它不起作用。

Answer 1

在最新版本中，missingTopicsFatal容器属性为true，这就是导致此问题的原因。你可以把它关掉...@Componentclass ContainerFactoryConfigurer {&nbsp; &nbsp; ContainerFactoryConfigurer(ConcurrentKafkaListenerContainerFactory<?, ?> factory) {&nbsp; &nbsp; &nbsp; &nbsp; factory.getContainerProperties().setMissingTopicsFatal(false);&nbsp; &nbsp; }}