storm ack机制流程详解

storm ack机制现在网上一堆资料。根据我的理解,对可靠版的word count进行了流程分析。 spout每发出一条信息,会根据用户指定的message id生成root id(假设为111),用于标记本次数据流;不论bolt还是spout,ack val = (输入tuple id) ^ (所有输出tuple id的异或结果),只不过ack val的输入tuple不存在。acker bol
相关文章
相关标签/搜索