Storm 全局分组容错

Question

我最近开始使用 Storm，但在网上找不到任何关于全局分组选项容错的资源。

根据我对文档的理解；而 运行 具有使用全局分组的 bolt（Bolt A）的拓扑将从 Bolt B 的任务接收元组到 Bolt A 的任务中。由于它使用全局分组选项，因此只有一个 Bolt 任务拓扑中的 A.

问题如下：如果我们在Bolt A中存储了一些stream的历史数据，包含Bolt A任务的worker进程挂掉了会怎样？这意味着存储在这个螺栓中的数据会丢失吗？

提前致谢

Answer 1

一旦所有下游任务都确认了元组，就意味着他们已经成功处理了消息，如果关闭则不需要重放。如果您在内存中保留任何状态，那么您应该将其存储在持久存储中。当由于消息而导致的状态更改已被持久化时，应确认消息。