Re: FW: Error using KafkaProducer EXACTLY_ONCE semantic + TaskManager Failure

2021-08-04 Thread Kevin Lam
t;> at >> org.apache.flink.streaming.connectors.kafka.internals.FlinkKafkaInternalProducer.createProducerIdAndEpoch(FlinkKafkaInternalProducer.java:291) >> ... 20 more >> >> Any ideas? >> >> On Tue, Aug 3, 2021 at 10:34 AM Schwalbe Matthias < >> matthias

Re: FW: Error using KafkaProducer EXACTLY_ONCE semantic + TaskManager Failure

2021-08-04 Thread Arvid Heise
0:34 AM Schwalbe Matthias < > matthias.schwa...@viseca.ch> wrote: > >> I don’t think that this risk is there, I guess Fabian a quick response … >> see also the later comments in the ticket. >> >> >> >> Thias >> >> >> >> *From:* Ke

Re: FW: Error using KafkaProducer EXACTLY_ONCE semantic + TaskManager Failure

2021-08-04 Thread Kevin Lam
gt; > > > Thias > > > > *From:* Kevin Lam > *Sent:* Dienstag, 3. August 2021 15:56 > *To:* Schwalbe Matthias > *Cc:* user ; fabianp...@ververica.com > *Subject:* Re: FW: Error using KafkaProducer EXACTLY_ONCE semantic + > TaskManager Failure > > > > Thank you

RE: FW: Error using KafkaProducer EXACTLY_ONCE semantic + TaskManager Failure

2021-08-03 Thread Schwalbe Matthias
I don’t think that this risk is there, I guess Fabian a quick response … see also the later comments in the ticket. Thias From: Kevin Lam Sent: Dienstag, 3. August 2021 15:56 To: Schwalbe Matthias Cc: user ; fabianp...@ververica.com Subject: Re: FW: Error using KafkaProducer EXACTLY_ONCE

FW: Error using KafkaProducer EXACTLY_ONCE semantic + TaskManager Failure

2021-08-03 Thread Schwalbe Matthias
… I just realized my former answer went only to Kevin directly. (Still exercising with the mail list 😊 ) This was my original answer, there is a workaround until the respective ticket is solved. Hope this helps Thias From: Schwalbe Matthias Sent: Freitag, 30. Juli 2021 08:13 To: Kevin Lam Sub