Team ,

I am working on Flink. Here is my requirement

1. Read the Events from Kafka
2. Apply Transfromation on the events
3. Sink to MongoDB
4. Produce Atomic Events to Kafka

Here, i am facing problem in implementing step 3, 4 in sequence.

1, 2 are connected by streams and DataStream will be output of Step2 , at present i am sending output of step 2 to step 3 , Step 4.

But i would like to implement step 3 then step 4.

1. I can return the output of Step 3 to Step 4, But Step 3 is just sinkToMongoDB i am not returning any from step 3.

I would like to build everything as pipeline and continuous stream.