diff --git a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/listener/QueueingMessageListenerInvoker.java b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/listener/QueueingMessageListenerInvoker.java
index 232cf6a195..2f5c1d9fc4 100644
--- a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/listener/QueueingMessageListenerInvoker.java
+++ b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/listener/QueueingMessageListenerInvoker.java
@@ -60,7 +60,7 @@ class QueueingMessageListenerInvoker implements Runnable, Lifecycle {
 		}
 		this.offsetManager = offsetManager;
 		this.errorHandler = errorHandler;
-		this.messages = new ArrayBlockingQueue<KafkaMessage>(capacity, true);
+		this.messages = new ArrayBlockingQueue<KafkaMessage>(capacity);
 	}
 
 	/**