Re: Flink Kafka Issue with EXACTLY_ONCE semantics

2022-04-11 Thread Frank Dekervel
Hello Praneeth, that looks correct then. In that case, maybe somebody else can chime in. Are you aware of this post on SO: https://stackoverflow.com/questions/45047876/apache-kafka-exactly-once-implementation-not-sending-messages Frank On Sat, Apr 9, 2022 at 7:42 PM Praneeth Ramesh wrote: >

Re: Flink Kafka Issue with EXACTLY_ONCE semantics

2022-04-09 Thread Praneeth Ramesh
Hi Frank Thanks for the response. I see that the min.isr value is 2 and replication factor is 4 in my case. Do you see any issues with these values..? Thank you in advance On Fri, Apr 8, 2022 at 11:28 PM Frank Dekervel wrote: > Hello, > > Check if your topic replication factor is not below mi

Re: Flink Kafka Issue with EXACTLY_ONCE semantics

2022-04-08 Thread Frank Dekervel
Hello, Check if your topic replication factor is not below min.isr setting of Kafka. I had the same problem and that was it for me. Frank Op za 9 apr. 2022 04:01 schreef Praneeth Ramesh : > Hi All > > I have a job which reads from kafka and applies some transactions and > writes the data back t