Storm の XOR による Acking framework - blog.sparsegraph.com

Wednesday, November 6, 2013 Storm の XOR による Acking framework Storm のメッセージ処理の保証をする枠組みが効率的で素敵だなと思ったので紹介します． 本エントリは，Storm ドキュメントの Guaranteeing message processing と Acking framework implementation の情報から Acker の動作に限定して解説し，サンプルコードとその実行時のデバッグログを追うという内容です． Storm は ack/emit による機構で１つ１つのメッセージ処理が最後まで行われることを保証することができます．これは「ストリームに流したメッセージの処理が失敗したら（emit したメッセージが ack されなかった場合），ストリームに流すコンポーネント（Spout）は流したメッセージの再送を行