我有一個使用 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"]但它不起作用。
1 回答

qq_花開花謝_0
TA貢獻1835條經驗 獲得超7個贊
在最新版本中,missingTopicsFatal容器屬性為true,這就是導致此問題的原因。你可以把它關掉...
@Component
class ContainerFactoryConfigurer {
ContainerFactoryConfigurer(ConcurrentKafkaListenerContainerFactory<?, ?> factory) {
factory.getContainerProperties().setMissingTopicsFatal(false);
}
}
添加回答
舉報
0/150
提交
取消