我正在开发一个使用 spring-kafka 的 Kafka 监听器的应用程序。我面临的问题是,当 Kafka 监听器未打开时,spring 上下文初始化失败(各种原因,例如 Kafka 服务器未打开或已关闭)。如何确保我的应用程序是独立的。

任何人都可以请帮忙。

最佳答案

在容器工厂上设置 autoStartup(false)

@AutowiredKafkaListenerEndpointRegistry 注入(inject)(例如 start() )到您的代码中(在 try/catch 中)。

您还可以通过从注册表中获取它们来单独启动/停止容器(使用 @KafkaListener id )。

关于spring - 即使Kafka监听器(spring-kafka)未初始化,如何启动spring应用程序,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/46136582/

10-16 17:20