Я понимаю, что max.spout.pending - это простой способ достичь противодавления с помощью acking-enabled. Я хочу понять, нужна ли нам еще max.spout.pending, чтобы теперь дросселировать носик, когда было выполнено противодавление?Дроссельная заслонка в Apache Storm
Спасибо!
От Storm 1.0.0 года, автоматизация противодавления предоставляется и конфигурируются с помощью высоких/низких водяных знаков (disruptor.highwatermark/disruptor.lowwatermark) для приемного буфера болта и размера буфера болта (executor.'receive/send'.buffer.size).
Итак, носик дросселирует/отпускает кортежи на болты на основе водяных знаков.
Для получения дополнительной информации см: http://storm.apache.org/2016/04/12/storm100-released.html
Можете ли вы указать на страницу, где упоминается эта реализация автоматического обратного давления? –
Не нужно, просто включите эту конфигурацию ** topology.backpressure.enable: true ** – Ajeesh