From da0f73029856d85a76694903fd0739c6abd89515 Mon Sep 17 00:00:00 2001
From: Marius Bogoevici <mbogoevici@pivotal.io>
Date: Mon, 9 Mar 2015 03:25:03 -0400
Subject: [PATCH] INTEXT-145 Do not set the queue to `fair`

---
 .../kafka/listener/QueueingMessageListenerInvoker.java          | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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);
 	}
 
 	/**