apache-storm - 在最多一次处理的情况下使用 BaseRichBolt 或 BaseBasicBolt

Question

我是 Storm 的初学者，我想知道我是否应该使用 BaseRichBolt或 BaseBasicBolt如果最多一次处理对我有好处？

据我了解 BaseBasicBolt元组会自动 anchor 定和确认，如果是 BaseRichBolt我们必须自己做。这是否意味着我应该使用 BaseRichBolt如果我想要最多一次处理？

我的逻辑是 anchor 定和确认会不必要地使事情变慢，对吗？

Answer 1

为了在 Storm 中启用容错，Spouts 需要为它们发出的元组分配消息 ID。只要没有分配消息 ID，确认和 anchor 定就不起作用。

因此，开销是BaseBasicBolt has 很小，您应该无法衡量任何性能差异。当然，使用 BaseRichBolt将完全避免这种微小的开销。