ターゲットシステムがダウンしたときにSpring Cloud Stream @StreamListenerがリッスンするのを停止します

Question

私はカフカからメッセージを取得し、ターゲットシステムを呼び出して従来のOracle DBを更新するアプリケーションを持っています。

対象システムがダウンしている場合、メッセージをKafkaバスに残し、一定期間処理しないシナリオを有効にしたいと考えています。 Circuit-breaker Hystrixベースのソリューションを検討していましたが、Spring Cloud Streamにリスニングイベントを「停止」させる仕組みは見つかりませんでした。私が考えることができる唯一の他の選択肢は、サーキットブレーカが開いている場合、これらのメッセージをエラー/再処理のトピックに転送することですが、それは私のアンチパターンのように聞こえるでしょう。私はは、イベントを処理することからシステムを一時停止することができます、それはマイクロサービスアプリのパブ/サブの利点です。

どのようなヘルプもうまくいくでしょう。

Answer 1

1つの解決策は、アプリケーションコンテキストを自動配線することです。

@Autowired 
private ConfigurableApplicationContext context; 

することはできstop()とstart()コンテキスト。

あなたはしかし@StreamListenerを呼び出し、または（ - ウサギのバインダーと、少なくともコンテナは、デフォルトでは5秒間に終了し、そのスレッドを待ちますので）停止が遅れることになるスレッドでstop()を呼び出すべきではありません。

もちろん、JMXや何らかの制御トピックをリスンする別のアプリケーションコンテキストなど、何らかのアウトオブバンドメカニズムを再起動する必要があります。