当目标系统关闭时，停止Spring Cloud Stream@StreamListener监听

Question

我有一个应用程序，从Kafka获取消息，并调用目标系统来更新遗留的Oracle DB。

我想启用一个场景，如果目标系统关闭，将消息留在Kafka总线上，并且在给定的时间段内不处理它们。我在考虑一些基于Hystrix的断路器解决方案，但我找不到任何机制来告诉Spring Cloud Stream“停止”事件监听。我能想到的另一种选择是，如果断路器断开，将这些信息传输到错误/重新处理主题，但这听起来像是一种反模式。我应该可以暂停系统处理事件，这就是微服务应用中酒吧/酒吧的全部优势。

任何帮助都将受到感谢。

Answer 1

一种解决方案是自动连接应用程序上下文。

@Autowired
private ConfigurableApplicationContext context;

您可以stop（）和start（）上下文。

但是，您不应该在调用@StreamListener的线程上调用stop（），否则停止将被延迟（因为容器将在默认情况下等待该线程退出5秒钟——至少使用兔子绑定器）。

当然，您需要某种带外机制来重新启动—可能是JMX或一个单独的应用程序上下文监听某种控制主题。