kamalcph commented on code in PR #20203:
URL: https://github.com/apache/kafka/pull/20203#discussion_r2217832101
##########
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:
RemoteLogMetadataManager is a public API change and require a KIP to add a
new method.
--
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]
