diff --git a/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java b/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java
index c398595..e5fbb66 100644
--- a/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java
+++ b/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java
@@ -1506,6 +1506,7 @@ public class KinesisMessageDrivenChannelAdapter extends MessageProducerSupport
 									}
 								}
 								catch (Exception e) {
+									lockFuture.complete(false);
 									logger.error("Error during locking: " + lock, e);
 								}
 							}