Correct. If you want to have guarantees between Sink1 and Sink2, you need
to create a combined sink
Op zo 8 jan. 2023 om 15:57 schreef Great Info
> 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,
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, 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
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 wrote:
>
> I have a stream from Kafka, after readi
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(
flinkKafkaPr
