Github user kailashhd commented on the issue:
https://github.com/apache/flink/pull/5663
Sorry for the delay in this. Confirming that I tested this using kinesalite
and kinesis for both the consumer and producer functionality. I had some
trouble when connecting this to kinesalite due to the following issue for
consumers [FLINK-8936]. I am planning on fixing this in the next iteration and
did not want for cleaner modular PRs. ---
