Hi, I have a Storm Topology composed of a AMPQ_Spout and a bolt capable of
writing to a MongoDB Collection

The problem is that once I run the Java Rabbitmq program that sends tuples
to Rabbitmq queue; the Storm topology pulls the Rabbitmq taking 100 tuples
and waiting for some minutes before it pulls another bunch of 100 tuples.

I have revised all the code and simplified the system as much I could but I
still have the same problem

does anybody have any clue of what can be happening or at least how to
detect where's this weird bottleneck?

thanks
David

Reply via email to