次のようなストリームがあります。ソース(jms-ibmmq) -> プロセス -> プロセス -> シンク(jdbc-oracle)
データの取り込みは正常に機能します。しかし、ストリームの一部として、シンク (jdbc-oracle) がダウンする可能性があります (または) oracle db への永続性を妨げるネットワークに問題がある可能性があります。
私が求めているのは、この失敗を処理する方法と、Spring xd がすぐに提供できるオプションは何ですか? 処理/シンクモジュールを引き起こしたストリームでこれらの障害を処理するために一般的に使用されるパターンはありますか?
この JIRA の問題に関するコメントを参照してください。メッセージ バスで配信不能文字を構成する方法を説明するために追加するドキュメントの変更について説明しています。
さらに、4 つのモジュールすべてが同じコンテナー (およびデプロイ基準に一致するすべてのコンテナー) にデプロイされた場合、シンクのエラーがサーバーにスローされるようにモジュールを直接接続するメカニズムを提供しました。 source (あなたのケースでは JMS メッセージがロールバックされます)。
これは、モジュールcountプロパティを0(条件に一致するすべてのコンテナー (存在する場合) またはすべてのコンテナー (条件がない場合) にデプロイすることを意味します) に設定することによって実現されます。
この機能は master で利用できます (M7 以降に追加されました)。