jiafu1115 commented on code in PR #20203:
URL: https://github.com/apache/kafka/pull/20203#discussion_r2478557577
##########
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java:
##########
@@ -375,6 +374,11 @@ private void
initializeResources(TopicBasedRemoteLogMetadataManagerConfig rlmmCo
}
}
}
+ @Override
+ public void onBrokerReady() {
+ log.info("Broker is ready for requests, now initializing topic-based
RLMM resources");
+ initializationThread.start();
Review Comment:
@chia7712 Thanks for your advice. Done for change.
https://github.com/apache/kafka/pull/20203/files#diff-50bf08ff4e92c16dfbea9239c89467a3ebf5fa38e5f4ea44ed4acff80013136eR379
<img width="739" height="237" alt="image"
src="https://github.com/user-attachments/assets/23cdc284-797f-44b9-993a-a4ed6a3c9804";
/>
BTW, I didn’t add the case into java doc for _local cluster – other machine_
because I don’t think anyone would do that.
--
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]
