Storm的ACK机制与编码实例

Storm为了保证每条数据成功被处理,实现至少一次语义,经过Storm的ACK机制能够对spout产生的每个tuple进行跟踪;php tuple处理成功是指这个Tuple以及这个Tuple产生的全部子Tuple都被成功处理, 由每个处理bolt经过OutputCollector的方法ack(tuple)来告知storm当前bolt处理成功,最终调用spout的ack方法;html 处理失败是指这
相关文章
相关标签/搜索