我有一个应用程序，它从kafka获取消息并调用目标系统来更新遗留的oracle数据库。
我想启用这样一个场景：如果目标系统关闭，将消息留在kafka总线上，并且在给定的时间段内不处理它们。我在考虑一些基于hystrix的断路器解决方案，但是我找不到任何机制来告诉springcloudstream“停止”事件监听。我能想到的另一种选择是，如果断路器断开，将这些消息传输到错误/重新处理主题，但这听起来像是反模式。我应该可以暂停系统处理事件，这是微服务应用程序中pub/sub的全部优势。
任何帮助都将受到感谢。