Currently distributed streams sends all keys provided in filterKeys to each node. We could improve this in 2 ways.
- Only send requests to nodes that have segments that map to desired keys
- We would also have to cross check this if user supplied specific segments
- 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.