Hi Gordan, Appreciate your prompt reply. Thanks alot for pointing that out that Kafka Producer has at least once guarantee of message delivery. That seems to be the reason why I encountered duplicated data on a flink failure recovery scenario.
-- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Data-duplication-on-a-High-Availability-activated-cluster-after-a-Task-Manager-failure-recovery-tp12627p12846.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.