From 586c7c83d01df5e27deaa61640adf0bfcacb4dff Mon Sep 17 00:00:00 2001 From: Guozhang Wang Date: Thu, 23 Oct 2014 11:32:43 -0700 Subject: [PATCH] Fix KAFKA-1501 --- core/src/main/scala/kafka/network/SocketServer.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala index cee76b3..c83816e 100644 --- a/core/src/main/scala/kafka/network/SocketServer.scala +++ b/core/src/main/scala/kafka/network/SocketServer.scala @@ -253,6 +253,7 @@ private[kafka] class Acceptor(val host: String, serverChannel.configureBlocking(false) serverChannel.socket().setReceiveBufferSize(recvBufferSize) try { + serverChannel.socket.setReuseAddress(true) serverChannel.socket.bind(socketAddress) info("Awaiting socket connections on %s:%d.".format(socketAddress.getHostName, port)) } catch { -- 1.7.12.4