Hi all, I want to duplicate records to multiple downstream tasks (not all of them thus the Broadcasting should not work) in stream environment. However, it seems that the current custom partitioner can return only one partition index. Why this restriction exists or do I miss something?
Thanks, Xingcan
