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 800c5c2..a55056e 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
@@ -252,10 +252,10 @@ public class KinesisMessageDrivenChannelAdapter extends MessageProducerSupport i
 	@Override
 	public void destroy() throws Exception {
 		if (!this.consumerExecutorExplicitlySet) {
-			((ExecutorService) this.consumerExecutor).shutdownNow();
+			((ExecutorService) this.consumerExecutor).shutdown();
 		}
 		if (!this.dispatcherExecutorExplicitlySet) {
-			((ExecutorService) this.dispatcherExecutor).shutdownNow();
+			((ExecutorService) this.dispatcherExecutor).shutdown();
 		}
 	}