storm消息容错机制

1、Storm 消息容错机制(掌握) 对于每个Spout Tuple保存一个ack-val的校验值,它的初始值为0,然后每发射一个tuple或者ack一个tuple,tuple的id都要跟这个校验值异或一下,并且把得到的值更新为ack-val的新值。   <ROOTID,ACKVALUE> 1.1、总体介绍 在storm中,可靠的信息处理机制是从spout开始的。 一个提供了可靠的处理机制的spo
相关文章
相关标签/搜索