Hi! I came across this comment for KafkaIO.Write.withEOS in Beam 2.6.0:
"Flink runner is * one of the runners whose checkpoint semantics are not compatible with current * implementation (hope to provide a solution in near future)" I would like to know if the Java docs are up to date and this support is still absent? If yes, then is there a way to get EOS for end to end applications written with Beam and Flink runner using Kafka sources/sinks? Is there a contribution possible for this support?
