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

Reply via email to