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  
相關文章
相關標籤/搜索