Github user tweise commented on the issue:
    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 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?


Reply via email to