Hi Mejri, Have you checked side outputs? https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/dev/datastream/side_output/
On Mon, Jun 3, 2024 at 8:28 AM mejri houssem <mejrihousse...@gmail.com> wrote: > Hello community, > > We have a use case in our Flink job that requires the implementation of > multiple sinks. I need to filter messages based on certain conditions > (information in the message) to determine which sink to dispatch them to. > > To clarify, I would like to implement logic in the operator that precedes > the sink in the job workflow, similar to the following: > > - If the condition is met, send the message to the first sink. > - Otherwise, send the message to the second sink. > > Is it possible to implement this in Flink? > > Thank you in advance for your assistance. > > Best regards, >
