showuon commented on code in PR #15530:
URL: https://github.com/apache/kafka/pull/15530#discussion_r1528009016
##########
core/src/main/scala/kafka/server/KafkaServer.scala:
##########
@@ -617,14 +617,21 @@ class KafkaServer(
}
}
}
- socketServer.enableRequestProcessing(authorizerFutures)
+ val enableRequestProcessingFuture =
socketServer.enableRequestProcessing(authorizerFutures)
// Block here until all the authorizer futures are complete
try {
CompletableFuture.allOf(authorizerFutures.values.toSeq: _*).join()
} 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 {
+ enableRequestProcessingFuture.join()
+ } catch {
+ case t: Throwable => throw new RuntimeException("Received a fatal
error while " +
+ "waiting for the SocketServer Acceptors to be started.", t)
+ }
Review Comment:
Fair enough.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
