KAFKA-14908: Set setReuseAddress on the kafka server socket

Aids use-cases where kafka is started/stopped on the same port, such as embedded testing. Signed-off-by: kwall <kwall@apache.org>
apache · Apr 18, 2023 · 55313ce · 55313ce
1 parent 454b721
commit 55313ce
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala
@@ -723,6 +723,7 @@ private[kafka] abstract class Acceptor(val socketServer: SocketServer,
         new InetSocketAddress(host, port)
     val serverChannel = ServerSocketChannel.open()
     serverChannel.configureBlocking(false)
+    serverChannel.socket().setReuseAddress(true);
     if (recvBufferSize != Selectable.USE_DEFAULT_BUFFER_SIZE)
       serverChannel.socket().setReceiveBufferSize(recvBufferSize)