Hi, I have a use case where I need to process incoming records on a Kafka topic based on a certain record field that defines the record type.
What I'm thinking is to split the incoming datastream into record-type specific streams and then apply record-type specific stream processing on each. What's the recommended way to achieve this in PyFlink? Are side outputs supported in PyFlink (I couldn't find any reference in the codebase)? Or do I have to replicate the input datastream and then apply record specific filters? Thanks, Sumeet
