I have a stream from Kafka, after reading it and doing some transformations/enrichment I need to store the final data stream in the database and publish it to Kafka so I am planning to add two sinks like below
*finalInputStream.addSink(dataBaseSink); // Sink1finalInputStream.addSink( flinkKafkaProducer ); //Sink2 * Has the sequence guaranteed between Sink1 and Sink2, in my requirement stream to sink2 should start to begin only after successfully completing Sink1, If Sink1 fails it should not write to Sink2.
