From b5e629eae72938edb0ae634d1a6f412e558e2416 Mon Sep 17 00:00:00 2001 From: Sriharsha Chintalapani Date: Fri, 26 Sep 2014 15:39:46 -0700 Subject: [PATCH] KAFKA-1577. Exception in ConnectionQuotas while shutting down. added selector operation to refresh selector.keys. --- core/src/main/scala/kafka/network/SocketServer.scala | 2 ++ 1 file changed, 2 insertions(+) diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala index 3a6f8d1..7ca79d5 100644 --- a/core/src/main/scala/kafka/network/SocketServer.scala +++ b/core/src/main/scala/kafka/network/SocketServer.scala @@ -172,6 +172,8 @@ private[kafka] abstract class AbstractServerThread(connectionQuotas: ConnectionQ * Close all open connections */ def closeAll() { + // removes cancelled keys from selector.keys set + this.selector.selectNow() val iter = this.selector.keys().iterator() while (iter.hasNext) { val key = iter.next() -- 1.8.5.2 (Apple Git-48)