You are using a Dataflow streaming job to read messages from a message bus that does not support exactly-once delivery. Your job then applies some transformatio...