Does it mean sequence of writing is not guaranteed between these
independent Sink1 and Sink2?




On Fri, 6 Jan 2023, 10:44 am Shammon FY, <zjur...@gmail.com> wrote:

> Hi @Great
>
> I think the two sinks in your example are equivalent and independent. If
> there are some logical relationships between two sinks, you may need to
> create a new combined sink and do it yourself.
>
> On Thu, Jan 5, 2023 at 11:48 PM Great Info <gubt...@gmail.com> wrote:
>
>>
>> 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.
>>
>

Reply via email to