Hi, I was going through the blog post on how TwoPhaseCommitSink function works with Kafka 11. One of the things I don’t understand is: What is the behavior of the Kafka 11 Producer between two checkpoints? Say that the time interval between two checkpoints is set to 15 minutes. Will Flink buffer all records in memory in that case and start writing to Kafka when the next checkpoint starts?
Thanks! -- Regards, Harshvardhan
