Github user kailashhd commented on the issue:
https://github.com/apache/flink/pull/5992
Please note I rebased my changes to the master as I was having some
failures when building just the flink-connector-kinesis maven project. I hope
this will not cause problems with reviewing the code changes. Sorry for the
inconvenience if it does. :( ---
