You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by saurabh mimani <mi...@gmail.com> on 2017/11/02 13:12:43 UTC

Is there some config to control number of tuples a storm bolt is processing

Hi,

Is there some config which can control how many tuples a storm bolt is
processing. So that bolt stops receiving more tuples if it has not
processed X message. There is such config: topology.max.spout.pending at
topology level.

Also I see in version 1.0.0
<http://storm.apache.org/2016/04/12/storm100-released.html> and mentioned
here
<http://www.michael-noll.com/blog/2013/06/21/understanding-storm-internal-message-buffers/>,
there is config to control topology.executor.receive.buffer.size and topolo
gy.executor.send.buffer.size which controls incoming and outgoing queue.
And there are disruptor.highwatermark and disruptor.lowwatermark which can
help throttling, but these will not help to control how many messages are
being processes in one bolt. Also these configs are at topology level.



Best Regards

Saurabh Kumar Mimani