Storm學習筆記 - 消息容錯機制

Storm學習筆記 - 消息容錯機制 文章來自「隨筆」 http://jsynk.cn/blog/articles/153.html 1. Storm消息容錯機制概念 一個提供了可靠的處理機制的spout需要記錄自己emit（發射）的tuple（消息元祖），當下遊bolt處理tuple或者子tuple失敗時spout能夠重新發射。 Storm通過調用Spout的nextTuple()發送一個tup

>>阅读原文<<