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 49596b4..607e2c3 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
@@ -673,7 +673,6 @@ public class KinesisMessageDrivenChannelAdapter extends MessageProducerSupport i
 			shardConsumer.stop();
 		}
 		this.shardConsumers.clear();
-		this.consumerInvokers.clear();
 	}
 
 	/**