我的拓扑结构部分依赖于使用第三方API,该API限制15分钟窗口中的某些调用。最坏的情况下,利率限制将下降,螺栓将需要睡15分钟。不幸的是,我似乎不能告诉风暴在15分钟的任务上“睡觉”,但我希望我错了。
或者,是否有办法在风暴中绕过时间限制的任务?(有一个喷口喂另一个喷口吗?)
发布于 2013-08-30 15:38:22
我不知道任何允许您这样做的配置,而且配置也没有为此提供配置条目。
解决办法就像你建议的那样。当您从第三方API获得输出时,将其输入到一个专用的Spout中,然后再将其发送到“回调”Bolt。
发布于 2013-08-30 15:48:20
发布于 2013-09-02 21:31:33
可能需要检查TOPOLOGY_DISRUPTOR_WAIT_STRATEGY属性,如前面提到的这里
https://stackoverflow.com/questions/18536105
复制相似问题