apache-storm - Storm：可以为一个 bolt 设置更高的 topology.message.timeout.secs

Question

我的拓扑结构的一部分依赖于使用 3rd 方 API，该 API 将某些调用限制在 15 分钟窗口内。在最坏的情况下，速率限制将下降，并且螺栓需要休眠 15 分钟。不幸的是，我似乎无法告诉 Storm 在一项任务上“睡” 15 分钟，但我希望我错了。

或者，有没有办法在风暴中解决像这样的时间限制任务？（有一个喷嘴喂另一个喷嘴？）。

score 3 · Accepted Answer

我不知道任何允许您这样做的配置，并且Config没有为此提供配置条目。

解决方法如您所建议。当您从 3rd 方 API 获得输出时，将其提供给专用 Spout，后者又会将其发送到“回调”Bolt。

score 1 · Accepted Answer

1

可能想要检查这里TOPOLOGY_DISRUPTOR_WAIT_STRATEGY提到的属性

于 2013-09-02T21:31:33.607 回答

score 1 · Accepted Answer

你可能想看看ticktuple（但它只有 600 秒）

```
Config conf = new Config();
conf.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, 1);
```

所以看看这个

3 回答 3