kamalcph commented on code in PR #20203:
URL: https://github.com/apache/kafka/pull/20203#discussion_r2480266959
##########
core/src/main/scala/kafka/server/BrokerServer.scala:
##########
@@ -591,6 +600,15 @@ class BrokerServer(
"all of the SocketServer Acceptors to be started",
enableRequestProcessingFuture, startupDeadline, time)
+ brokerReadyCallbacks.foreach { callback =>
Review Comment:
subjective: My preference is to keep the change simple for now. If another
component requires the brokerReadyCallback, then the list of callbacks can be
maintained at that time.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
