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)
