apache-storm - 让 Storm 喷口等待 bolt 准备就绪

Question

现在 Storm Spouts 有一个 open 方法来配置它们，而 Bolts 有一个 prepare 方法。有没有办法让所有 Spout 实例等待 Bolt 上的所有 prepare 方法完成监听？

我有一个案例，我想将一些配置信息即时传递给 bolt (因为这个配置信息一直在变化)。我在一些地方读到我们应该使用 Zookeeper 或像 redis 这样的内存中键值存储来做到这一点。不过我担心的是，如果 Bolt 还没有准备好处理来自 Spout 的数据，并且 Spout 开始发出元组，会发生什么情况？有没有办法让 Spouts 等待 Bolts 的更新，说他们准备好了？

Answer 1

我为此找到了一个更优雅的解决方案(我认为)。问题是某些 bolt 需要配置信息才能处理传入的元组。我发现了 Storm 重放元组的能力，所以现在我的 bolt 从一个 spout 监听更新，从另一个 spout 监听元组。只要我没有收到更新，我就会一直让元组失败，并让 spout 在一段可配置的时间后重播它们。