chia7712 commented on code in PR #16584:
URL: https://github.com/apache/kafka/pull/16584#discussion_r2302951390
##########
clients/src/main/java/org/apache/kafka/clients/admin/OffsetSpec.java:
##########
@@ -91,4 +92,13 @@ public static OffsetSpec earliestLocal() {
public static OffsetSpec latestTiered() {
return new LatestTieredSpec();
}
+
+ /**
+ * Used to retrieve the earliest offset of records that are pending upload
to remote storage.
+ * <br/>
+ * Note: When tiered storage is not enabled, we will return unknown offset.
+ */
+ public static OffsetSpec earliestPendingUpload() {
Review Comment:
I mean this new public API
--
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
