diff --git a/core/src/main/java/io/aiven/kafka/tieredstorage/RemoteStorageManager.java b/core/src/main/java/io/aiven/kafka/tieredstorage/RemoteStorageManager.java index 976522c30..5ab057fd6 100644 --- 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();