Storm系列之二——Guaranteeing Message Processing

时间:2021-12-01 10:59:01

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

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

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

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

Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS,默认是30秒。