Scaling Streams Messaging Clusters