Storm的可靠性

1、Spout的可靠性保证      在Storm中,消息处理可靠性从Spout开始的。storm为了保证数据能正确的被处理, 一个提供了可靠的处理机制的spout需要记录它发射出去的tuple,当下游bolt处理tuple或者子tuple处理失败时spout能够重新发射。子tuple可以理解为bolt处理spout原始tuple。另外一个角度来看,可以将spout发射的数据流看作一个tuple数
相关文章
相关标签/搜索