I'm not even sure the core Beam engineers understand it all! Look at how Kafka offset acks are handled now: https://github.com/apache/beam/blob/master/sdks/ja

I'm not even sure the core Beam engineers understand it all! Look at how Kafka offset acks are handled now: https://github.com/apache/beam/blob/master/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaCommitOffset.java#L126 https://github.com/apache/beam/blob/master/sdks/java/io/kafk...