Hi, Can anyone point me to some notes on how storm decides to distribute the tasks among its workers. The behavior am seeing is that all tasks of a particular type are being grouped into one worker process. To add more details to my use-case, I have a spout that is sourcing tuples from a rabbitmq cluster. I want to distribute the spout tasks across different storm workers so that the throughput is higher and the load of ingesting the messages is distributed across all the workers in the storm cluster. Any suggestions on how to influence the distribution of tasks?
Thanks, Srinath.
