与えられたフィールドを持つすべてのタプルが処理されたかどうかを確かめるための嵐ボルト

Question

私は複数のタプルをペアレル数8で処理して処理した後、idを出して、次のボルトにインデックスを付けて、処理され、通知が送信されます。どのようにそれを行うことができますか？嵐は既にそれのためのimplementatinoを持っていますか？

Answer 1

ストームにはすでにメッセージ保証システムがあります。 BasicBoltクラスとBasicSpoutクラス（デフォルトで各タプルを受け付ける）を拡張するか、明示的にOutputCollectorクラスのackメソッドを呼び出すことによって、ボルトでこれを有効にする必要があります。

次に、Spoutのfailとackメソッドにロジックを追加する必要があります。 Message Guarantee APIの詳細はこちらです。

このシステムは、（スパウトによって放出された）タプルがあなたのトポロジを完全に通過しないかどうかを知らせます。エグゼキュータの間の各ステップの成功について知りたい場合は、ボルトにカスタムロジックを必要とするか、またはAckerの実装を変更します（推奨されません）。

ただし、各メッセージの正確な処理が保証されている場合は、おそらくTridentライブラリをご覧ください。