;Mahendra Hegde" , "Theo Diefenthal"
, "user"
Gesendet: Freitag, 14. Februar 2020 15:26:44
Betreff: Re: AW: How Flink Kafka Consumer works when it restarts
The main benefit of letting Flink keep the offsets is that you get exactly once
semantics (with the offsets in Fli
iefent...@scoop-software.de>
>> *Date: *Thursday, 13 February 2020 at 12:13 AM
>> *To: *"Hegde, Mahendra" , "
>> user@flink.apache.org"
>> *Subject: *[External] AW: How Flink Kafka Consumer works when it restarts
>>
>>
>>
>> Hi Ma
unicate with Kafka and ask kafka to poll messages
> starting from those offsets.
>
>
>
> Best regards
>
> Theo
>
>
>
>
> Von meinem Huawei-Telefon gesendet
>
>
>
> Ursprüngliche Nachricht
> Von: "Hegde, Mahendra"
> Datum: Mi.
Thanks Theo !
From: "theo.diefent...@scoop-software.de"
Date: Thursday, 13 February 2020 at 12:13 AM
To: "Hegde, Mahendra" , "user@flink.apache.org"
Subject: [External] AW: How Flink Kafka Consumer works when it restarts
Hi Mahendra,
Flink will regularly
17:50
An: user@flink.apache.org
Betreff: How Flink Kafka Consumer works when it restarts
Hi All,
I am bit confused on Flink kafka consumer working.
I read that Flink stores the kafka message offset in checkpoint and uses it in
case if it restarts.
Question is when exactly Flink is committing a
Hi All,
I am bit confused on Flink kafka consumer working.
I read that Flink stores the kafka message offset in checkpoint and uses it in
case if it restarts.
Question is when exactly Flink is committing about successful consumption
confirmation to kafka broker?
And when Flink job restarts will
