From de5b00ccd40c1cc9a4b0cdddaaaf8e2aacc86691 Mon Sep 17 00:00:00 2001 From: Chia-Ping Tsai Date: Thu, 18 Mar 2021 14:24:35 +0800 Subject: [PATCH] HOTFIX: the request thread in clientToControllerChannelManager is NOT started --- core/src/main/scala/kafka/server/BrokerServer.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/scala/kafka/server/BrokerServer.scala b/core/src/main/scala/kafka/server/BrokerServer.scala index 8689afd743d88..e861f1187a241 100644 --- a/core/src/main/scala/kafka/server/BrokerServer.scala +++ b/core/src/main/scala/kafka/server/BrokerServer.scala @@ -190,6 +190,7 @@ class BrokerServer( threadNamePrefix, retryTimeoutMs = 60000 ) + clientToControllerChannelManager.start() forwardingManager = new ForwardingManagerImpl(clientToControllerChannelManager) val apiVersionManager = ApiVersionManager(