首页 > 代码库 > Storm系列之二——Guaranteeing Message Processing

Storm系列之二——Guaranteeing Message Processing

Storm保证每跳离开spout的消息都会被完全处理。本文介绍Storm是怎么保证每条消息都被完全处理并且作为用户该怎么做才能从Storm的可靠性保证受益。

1、什么叫消息被完全处理?

    一个tuple从spout出发可以触发成千上万个tuples基于它。

    一个tuple被认为处理失败了,如果它的消息树在一个指定的时间内没有被完全处理。这个时间可以通过下面这样来配置:

    Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS,默认是30秒。

    

Storm系列之二——Guaranteeing Message Processing