storm ack机制流程详解

storm ack机制如今网上一堆资料。根据个人理解，对可靠版的word count进行了流程分析。函数 spout每发出一条信息，会根据用户指定的message id生成root id(假设为111)，用于标记本次数据流；不论bolt仍是spout，ack val = (输入tuple id) ^ (全部输出tuple id的异或结果)，只不过ack val的输入tuple不存在。acker b

>>阅读原文<<