Thanks a lot for the quick response! I can recall having already played with this when I first deployed this consumer and couldn't get around the following issue that I'm getting now again...
java.lang.IllegalArgumentException: Cannot output with timestamp 2019-10-09T03:12:04.250Z. Output timestamps must be no earlier than the timestamp of the current input (2019-10-09T03:12:04.292Z) minus the allowed skew (0 milliseconds). See the DoFn#getAllowedTimestampSkew() Javadoc for details on changing the allowed skew. How can I manage skew? Wouldn't it increase as it's happening with the current version which uses processing time? The timestamp that I'm inferring comes straight from the JSON object (which is the one looking forward to use) and not from PubSub itself.
