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 da24e08..ad7475b 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
@@ -776,8 +776,8 @@ public class KinesisMessageDrivenChannelAdapter extends MessageProducerSupport
 		super.doStop();
 		stopConsumers();
 
-		this.shardConsumerManagerFuture.cancel(true);
 		this.active = false;
+		this.shardConsumerManagerFuture.cancel(true);
 	}
 
 	private void stopConsumers() {