fixup! refactor: fetch and catch parts of segment instead of chunks

Aiven-Open · Oct 18, 2023 · 85dd305 · 85dd305
1 parent 58fb67f
commit 85dd305
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/core/src/main/java/io/aiven/kafka/tieredstorage/RemoteStorageManager.java b/core/src/main/java/io/aiven/kafka/tieredstorage/RemoteStorageManager.java
@@ -433,10 +433,7 @@ public InputStream fetchLogSegment(final RemoteLogSegmentMetadata remoteLogSegme
                 range.size());
 
             final var segmentManifest = fetchSegmentManifest(remoteLogSegmentMetadata);
-
-            final var suffix = ObjectKeyFactory.Suffix.LOG;
-            final var key = objectKey(remoteLogSegmentMetadata, suffix);
-
+            final var key = objectKey(remoteLogSegmentMetadata, ObjectKeyFactory.Suffix.LOG);
             final var fetchEnumeration = new FetchEnumeration(fetchManager, key, segmentManifest, range, partSize);
             maybePreFetch(key, segmentManifest, fetchEnumeration);
             return fetchEnumeration.toInputStream();