Часть моей топологии зависит от работы со сторонним API, который ограничивает скорость определенных вызовов в 15-минутных окнах. В худшем случае ограничение скорости сработает, и болту нужно будет заснуть на 15 минут. К сожалению, похоже, что я не могу сказать шторму «спать» над задачей в течение 15 минут, но я надеюсь, что ошибаюсь.
В качестве альтернативы, есть ли способ обойти такие ограниченные по времени задачи во время шторма? (нужен ли носик, питающий другой носик?).
Я не знаю ни одной конфигурации, позволяющей это сделать, и Config не предлагает запись конфигурации для этого.
Обходной путь, как вы предложили. Когда вы получите выходные данные от стороннего API, передайте их в выделенный Spout, который, в свою очередь, передаст их в Bolt «обратного вызова».
Вы можете взглянуть на ticktuple (но это только на 600 секунд)
```
Config conf = new Config();
conf.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, 1);
```
Взгляните на это
Может потребоваться проверить атрибут TOPOLOGY_DISRUPTOR_WAIT_STRATEGY, как указано здесь
