Storm的ack机制在项目应用中的坑

原文:http://www.cnblogs.com/intsmaze/p/5918087.html 先说一下ACK机制:   为了保证数据能正确的被处理, 对于spout产生的每一个tuple, storm都会进行跟踪。   这里面涉及到ack/fail的处理,如果一个tuple处理成功是指这个Tuple以及这个Tuple产生的所有Tuple都被成功处理, 会调用spout的ack方法;   如果
相关文章
相关标签/搜索