Looking more closely the filterKeys variable is passed as is to the cluster stream manager which then passes it as is. We need to filter out keys that map to the segments to avoid replicating too many keys.