diff --git a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/utils/TestConsumer.java b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/utils/TestConsumer.java
index 888c3ba7..f2581b39 100644
--- a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/utils/TestConsumer.java
+++ b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/utils/TestConsumer.java
@@ -125,7 +125,7 @@ public class TestConsumer {
          */
         log.info("Cancelling producer and shutting down executor.");
         producerFuture.cancel(false);
-        producerExecutor.shutdownNow();
+        producerExecutor.shutdown();
 
         /**
          * Wait a few seconds for the last few records to be processed