Github user tweise commented on the issue:
https://github.com/apache/flink/pull/5634
This is a good proposal, it should also survive a general connector
refactor that will be necessary to address other code duplication. The Kinesis
ticket is https://issues.apache.org/jira/browse/FLINK-5697 and I will add a
reference back to this thread. I would be happy to add the watermark support
based on the revised generator. Perhaps it would be good to recognize the
special "idle" watermark in SourceContext also?
---
