Thanks Jason for your answer. We tried by disabling ackers, and it worked. Could you please explain why it behaved differently when ack was enabled. Storm cluster has 25 acker threads for 25 workers.
Do we need to try anything different configurations? Regards, Shobha Rani Poli On Thu, Apr 10, 2014 at 3:41 AM, Jason Jackson <[email protected]> wrote: > does the problem still occur if you disable acking? conf.setNumAckers(0). > > > On Wed, Apr 9, 2014 at 9:48 AM, Shobha <[email protected]> wrote: > >> Hi All, >> We have storm cluster with 5 nodes, 25 spouts, 250 bolts, 25 workers. >> Storm is consuming the messages from kafka queue, and kafka queue has 214M >> items, spouts after consuming 181M items, the spouts stopped emitting the >> items. So killed the topology and redeployed it again, then it spouts >> started emitting the rest items. >> >> Noticed that only few spouts emitted the items after killing and >> redeploying the topology. >> >> Did anyone faced this problem, if so could anyone please suggest what >> might be the problem? >> >> >> Regards, >> Shobha Rani Poli >> > >
