dae*_*n54 3 spring apache-kafka spring-kafka
我正在使用一个使用spring-kafka的Kafka监听器的应用程序.我面临的问题是当Kafka监听器没有打开时弹簧上下文初始化失败(各种原因,例如Kafka服务器没有打开或关闭).如何确保我的应用程序是独立的.
谁能请帮忙.
设置autoStartup(false)在容器工厂.
在代码中注入(例如@Autowired)KafkaListenerEndpointRegistry和start()它(在try/catch中).
您也可以通过从注册表中获取容器来单独启动/停止容器(使用@KafkaListener id).
| 归档时间： |
|
| 查看次数： |
1659 次 |
| 最近记录： |