Storm的ACK机制与编码实例

Storm的ACK机制与编码实例 2016年10月25日 17:46:10 阅读数:5124 Storm为了保证每条数据成功被处理,实现至少一次语义,通过Storm的ACK机制可以对spout产生的每一个tuple进行跟踪; tuple处理成功是指这个Tuple以及这个Tuple产生的所有子Tuple都被成功处理, 由每一个处理bolt通过OutputCollector的方法ack(tuple)来
相关文章
相关标签/搜索