I am trying to achieve exactly one semantics using Flink and Kafka. I have explained my scenario thoroughly in this post https://stackoverflow.com/questions/70622321/exactly-once-in-flink-kafka-producer-and-consumer
Any help is much appreciated! Thanks, Sid