向 Storm 拓扑添加交互元素

Question

我有一个拓扑结构，可以将目前无法处理的数据保存到一个特殊的数据库中。一旦我添加了处理数据的能力，我希望能够告诉拓扑"Go and process a block of leftover data from [time A] to [time B]"。

有没有"stormic"（这是一个词？）的实现方式吗？例如通过向 Storm 添加交互元素（按钮、输入字段）UI?

Answer 1

我认为没有内置这样的东西。您可能会做的是将无法处理的记录写入某个地方（例如 Kafka），直到您可以处理它们。当您可以处理它们时，您可以通过将不可处理的记录主题添加到 Kafka 输入主题来让 Storm 拾取它们，或者启动仅从不可处理的记录数据源中使用的拓扑的另一个副本。