Kafka からメッセージを取得し、ターゲット システムを呼び出してレガシー Oracle DB を更新するアプリケーションがあります。
ターゲット システムがダウンしている場合、メッセージを Kafka バスに残し、一定期間処理しないシナリオを有効にしたいと考えています。サーキットブレーカーの Hystrix ベースのソリューションを考えていましたが、Spring Cloud Stream にイベントのリッスンを「停止」するように指示するメカニズムが見つかりません。私が考えることができる他の唯一の代替手段は、サーキットブレーカーが開いている場合に、これらのメッセージをエラー/再処理トピックに転送することですが、それはアンチパターンのように思えます。システムがイベントを処理するのを一時停止できるはずです。これが、マイクロ サービス アプリでの pub/sub の利点です。
どんな助けでも感謝します。