Github user tweise commented on the issue:
https://github.com/apache/flink/pull/5634
There was a related discussion on the mailing list; this and several other
features could be provided by a common connector framework. Such initiative is
a much larger effort though and it is not clear to me that users can wait? The
Kinesis consumer has virtually identical requirements and we have already
written custom code for it.---
