Hey folks, I have a program that demultiplexes input records from a shared prefix stream onto some number of suffix streams, which are allocated on boot based on configuration.
At the moment I'm just duplicating the input records, and filtering out the wrong records in each suffix stream, but it's not super efficient... Unfortunately, from what I can see, using side outputs isn't an option because each output tag has a single type parameter, and the output record is dispatched based on its runtime type. Is there a better way to do this? Thanks! -0xe1a
