Currently distributed streams sends all keys provided in filterKeys to each node. We could improve this in 2 ways.

1. Only send requests to nodes that have segments that map to desired keys
   1. We would also have to cross check this if user supplied specific segments
2. Only send the keys that map to the nodes that have those segments instead of all

This should reduce possible # of messages and for sure reduce message payloads.