This is an automated email from the ASF dual-hosted git repository. showuon pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push: new 4cb6806cb8f KAFKA-16232: kafka hangs forever in the starting process if the authorizer future is not returned (#15549) 4cb6806cb8f is described below commit 4cb6806cb8f1cdbf9f47cb6521127fd3f49fa712 Author: Kuan-Po (Cooper) Tseng <brandb...@gmail.com> AuthorDate: Thu Mar 28 10:31:22 2024 +0800 KAFKA-16232: kafka hangs forever in the starting process if the authorizer future is not returned (#15549) add logs before and after future waiting, to allow admin to know we're waiting for the authorizer future. Reviewers: Luke Chen <show...@gmail.com> --- core/src/main/scala/kafka/server/KafkaServer.scala | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/core/src/main/scala/kafka/server/KafkaServer.scala b/core/src/main/scala/kafka/server/KafkaServer.scala index fce61e17a22..3d41f01b704 100755 --- a/core/src/main/scala/kafka/server/KafkaServer.scala +++ b/core/src/main/scala/kafka/server/KafkaServer.scala @@ -617,17 +617,22 @@ class KafkaServer( } } } + val enableRequestProcessingFuture = socketServer.enableRequestProcessing(authorizerFutures) // Block here until all the authorizer futures are complete try { + info("Start processing authorizer futures") CompletableFuture.allOf(authorizerFutures.values.toSeq: _*).join() + info("End processing authorizer futures") } catch { case t: Throwable => throw new RuntimeException("Received a fatal error while " + "waiting for all of the authorizer futures to be completed.", t) } // Wait for all the SocketServer ports to be open, and the Acceptors to be started. try { + info("Start processing enable request processing future") enableRequestProcessingFuture.join() + info("End processing enable request processing future") } catch { case t: Throwable => throw new RuntimeException("Received a fatal error while " + "waiting for the SocketServer Acceptors to be started.", t)