storm消息机制保证ack 原理

 storm会有一个ackbolt 不断计算top 每个spout,bolt task的msgid ,来确认调用act 方法还是fail方法 ； 如下示列 1.如下图       1.spout 向ackbolt 报上去的 rootId=T1^T2  2.bolt1 向ackbolt 报上去的 rootId=T1^T3^T4^T5  3.bolt2 向ackbolt 报上去的rootId=T2  

>>阅读原文<<