Storm容錯機制Acker詳解和實戰案例

Storm中有個特殊的Executor叫acker，他們負責跟蹤spout發出的每一個Tuple的Tuple樹。當acker發現一個Tuple樹已經處理完成了，它會告訴框架回調Spout的ack()，否則回調Spout的fail()。 Acker的跟蹤算法是Storm的主要突破之一，對任意大的一個Tuple樹，它只需要恆定的20字節就可以進行跟蹤。 我們期望的是，如果某個Tuple被Bolt執行失

>>阅读原文<<