spout sends tuples just to a subset of bolt instances

Question

I'm just starting with storm. I have a simple topology of a spout (1 executor) and a bolt (4 executors). The spout and the bolt are connected via "shuffleGrouping".

From what I can see the spout sends tuples only to a subset of bolt executors - the ones that are running on the same host as the spout.

Is this expected? Is there a way to spread the load across all bolt executors no matter where they run?

Answer 1

Yes, it's expected. I think you can config it by using same spout source, like storm integrate with kafka,then you create 2 topologies, config each spout of each topology with the same topic and same zookeeper host.