Hi All,

We are using apache storm to read msgs from kafka queues. Traffic usually
is high in these kafka queues so processing is almost real time. But I'm
facing one problem when load is relatively low and spout doesn't have msgs
to read. In this case, the spout will go into sleep for sometime (~5
seconds) depending upon my sleep/backoff strategy. During this spout sleep
interval, If there is a msg available in kafka queues, my spout will not
read it. Spout will only be able to process the msg once the sleep/backoff
time is done. Hence there is a delay or around 3-4 sec in processing of
that msg. Is there any way present in Apache Storm to notify the sleeping
spout so that it can start processing again?

Any leads are highly appreciated.

*Thanks & Regards*
*Mohit Goyal*

Reply via email to