Storm的ack原理和使用

Storm的ack原理 经过Ack机制,spout发送出去的每一条消息,均可以肯定是被成功处理或失败处理, 从而可让开发者采起动做。好比在Meta中,成功被处理,便可更新偏移量,当失败时,重复发送数据。 所以,经过Ack机制,很容易作到保证全部数据均被处理,一条都不漏。 另外须要注意的,当spout触发fail动做时,不会自动重发失败的tuple,须要spout本身从新获取数据,手动从新再发送一次
相关文章
相关标签/搜索