brandboat commented on code in PR #16783:
URL: https://github.com/apache/kafka/pull/16783#discussion_r1702431351
##########
clients/src/main/java/org/apache/kafka/clients/admin/OffsetSpec.java:
##########
@@ -70,4 +72,21 @@ public static OffsetSpec maxTimestamp() {
return new MaxTimestampSpec();
}
+ /**
+ * Used to retrieve the offset with the local log start offset,
+ * log start offset is the offset of a log above which reads are
guaranteed to be served
+ * from the disk of the leader broker, when Tiered Storage is not enabled,
it behaves the same
+ * as the earliest timestamp
+ */
+ public static OffsetSpec earliestLocalSpec() {
+ return new EarliestLocalSpec();
+ }
+
+ /**
+ * Used to retrieve the offset with the highest offset of data stored in
remote storage,
+ * and when Tiered Storage is not enabled, we won't return any offset
(i.e. Unknown offset)
Review Comment:
Thanks for the comments, already fixed them in the latest commit.
--
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]
