From abb589c467a752e071280764ff34cef716be45b1 Mon Sep 17 00:00:00 2001
From: jqin <becket.qin@gmail.com>
Date: Tue, 11 Nov 2014 14:58:16 -0800
Subject: [PATCH] fix for KAFKA-1764

---
 core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala b/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
index fbc680f..2402b45 100644
--- a/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
+++ b/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
@@ -256,7 +256,7 @@ private[kafka] class ZookeeperConsumerConnector(val config: ConsumerConfig,
   }
 
   private def sendShutdownToAllQueues() = {
-    for (queue <- topicThreadIdAndQueues.values) {
+    for (queue <- topicThreadIdAndQueues.values.toSet) {
       debug("Clearing up queue")
       queue.clear()
       queue.put(ZookeeperConsumerConnector.shutdownCommand)
-- 
1.8.3.4 (Apple Git-47)