diff --git a/clients/src/main/java/org/apache/kafka/common/requests/ListOffsetsRequest.java b/clients/src/main/java/org/apache/kafka/common/requests/ListOffsetsRequest.java index 065a0b5d8a8..7415412d050 100644 --- a/clients/src/main/java/org/apache/kafka/common/requests/ListOffsetsRequest.java +++ b/clients/src/main/java/org/apache/kafka/common/requests/ListOffsetsRequest.java @@ -66,7 +66,7 @@ public class ListOffsetsRequest extends AbstractRequest { boolean requireMaxTimestamp, boolean requireEarliestLocalTimestamp, boolean requireTieredStorageTimestamp) { - short minVersion = 0; + short minVersion = ApiKeys.LIST_OFFSETS.oldestVersion(); if (requireTieredStorageTimestamp) minVersion = 9; else if (requireEarliestLocalTimestamp) @@ -81,7 +81,7 @@ public class ListOffsetsRequest extends AbstractRequest { } public static Builder forReplica(short allowedVersion, int replicaId) { - return new Builder((short) 0, allowedVersion, replicaId, IsolationLevel.READ_UNCOMMITTED); + return new Builder(ApiKeys.LIST_OFFSETS.oldestVersion(), allowedVersion, replicaId, IsolationLevel.READ_UNCOMMITTED); } private Builder(short oldestAllowedVersion, diff --git a/clients/src/test/java/org/apache/kafka/common/requests/ListOffsetsRequestTest.java b/clients/src/test/java/org/apache/kafka/common/requests/ListOffsetsRequestTest.java index 2aa2f0c150b..2cf4cbc00c9 100644 --- a/clients/src/test/java/org/apache/kafka/common/requests/ListOffsetsRequestTest.java +++ b/clients/src/test/java/org/apache/kafka/common/requests/ListOffsetsRequestTest.java @@ -135,7 +135,7 @@ public class ListOffsetsRequestTest { ListOffsetsRequest.Builder requireTieredStorageTimestampRequestBuilder = ListOffsetsRequest.Builder .forConsumer(false, IsolationLevel.READ_UNCOMMITTED, false, false, true); - assertEquals((short) 0, consumerRequestBuilder.oldestAllowedVersion()); + assertEquals((short) 1, consumerRequestBuilder.oldestAllowedVersion()); assertEquals((short) 1, requireTimestampRequestBuilder.oldestAllowedVersion()); assertEquals((short) 2, requestCommittedRequestBuilder.oldestAllowedVersion()); assertEquals((short) 7, maxTimestampRequestBuilder.oldestAllowedVersion());