即使 Kafka 侦听器 (spring-kafka) 未初始化,如何启动 spring 应用程序
How to start spring application even if Kafka listener (spring-kafka) doesn't initialize
我正在开发一个使用 spring-kafka 的 Kafka 侦听器的应用程序。我面临的问题是,当 Kafka 侦听器未开启时 spring 上下文初始化失败(各种原因,例如 Kafka 服务器未开启或已关闭)。如何确保我的应用程序是独立的。
谁能帮忙。
在容器工厂上设置autoStartup(false)
。
在您的代码中(在 try/catch 中)注入(例如 @Autowired
)KafkaListenerEndpointRegistry
和 start()
。
您还可以 start/stop 容器,方法是从注册表中获取它们(使用 @KafkaListener
id
)。
我正在开发一个使用 spring-kafka 的 Kafka 侦听器的应用程序。我面临的问题是,当 Kafka 侦听器未开启时 spring 上下文初始化失败(各种原因,例如 Kafka 服务器未开启或已关闭)。如何确保我的应用程序是独立的。
谁能帮忙。
在容器工厂上设置autoStartup(false)
。
在您的代码中(在 try/catch 中)注入(例如 @Autowired
)KafkaListenerEndpointRegistry
和 start()
。
您还可以 start/stop 容器,方法是从注册表中获取它们(使用 @KafkaListener
id
)。