Hi, It's version 1.5.2.
I actually found the place in the code responsible for it. In the "catch" block, it doesn't log the error and it lets it propagate. https://github.com/apache/flink/blob/62839e88e15b338a8af9afcef698c38a194c592f/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
