jiafu1115 commented on code in PR #20203:
URL: https://github.com/apache/kafka/pull/20203#discussion_r2229826196
##########
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadataManager.java:
##########
@@ -242,4 +242,18 @@ default Optional<RemoteLogSegmentMetadata>
nextSegmentWithTxnIndex(TopicIdPartit
default boolean isReady(TopicIdPartition topicIdPartition) {
return true;
}
+
+ /**
+ * Register a listener for when the broker is ready to serve requests.
+ * This method will be called during initialization if the implementation
+ * supports delayed initialization until the broker can process requests.
+ *
+ * The default implementation does nothing, allowing implementations that
don't
+ * need delayed initialization to ignore this method.
+ *
+ * @param brokerReadyFuture A CompletableFuture that completes when broker
is ready to serve requests
+ */
+ default void onBrokerReadyForRequests(CompletableFuture<Void>
brokerReadyFuture) {
Review Comment:
Ok. It seems that I have to write one now. Thanks
--
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
