[runT1ME]

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/kafk...