我有一个拓扑结构，它将目前无法处理的数据保存到一个特殊的数据库中。一旦我添加了处理数据的功能，我希望能够告诉拓扑“去处理从[timea]到[timeb]的一块剩余数据”。有没有一个“风暴”（这是一个词？）的方式来实现这一点？例如，向storm ui添加交互元素（按钮、输入字段）？
kgsdhlau1#
我不认为这样的事情是天生的。你可能做的是把你不可处理的记录写到某个地方（例如Kafka），直到你可以处理它们。当您可以处理它们时，您可以通过将不可处理记录主题添加到kafka输入主题来让storm拾取它们，或者启动仅使用不可处理记录数据源的拓扑的另一个副本。
1条答案
按热度按时间kgsdhlau1#
我不认为这样的事情是天生的。你可能做的是把你不可处理的记录写到某个地方（例如Kafka），直到你可以处理它们。当您可以处理它们时，您可以通过将不可处理记录主题添加到kafka输入主题来让storm拾取它们，或者启动仅使用不可处理记录数据源的拓扑的另一个副本。