From cc5ada4ed4611bcaf6bb6bfa0ae029e28078dc39 Mon Sep 17 00:00:00 2001 From: Jay Kreps Date: Tue, 15 Jan 2013 15:48:26 -0800 Subject: [PATCH] KAFKA-702 Do not include a bound on queue size for the response queues in RequestChannel as that can lead to deadlock. :-( --- core/src/main/scala/kafka/network/RequestChannel.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/network/RequestChannel.scala b/core/src/main/scala/kafka/network/RequestChannel.scala index 0e5b7cb..848c877 100644 --- a/core/src/main/scala/kafka/network/RequestChannel.scala +++ b/core/src/main/scala/kafka/network/RequestChannel.scala @@ -98,7 +98,7 @@ class RequestChannel(val numProcessors: Int, val queueSize: Int) extends KafkaMe private val requestQueue = new ArrayBlockingQueue[RequestChannel.Request](queueSize) private val responseQueues = new Array[BlockingQueue[RequestChannel.Response]](numProcessors) for(i <- 0 until numProcessors) - responseQueues(i) = new ArrayBlockingQueue[RequestChannel.Response](queueSize) + responseQueues(i) = new LinkedBlockingQueue[RequestChannel.Response]() newGauge( "RequestQueueSize", -- 1.8.0.2