From 353ade2f9cdcad3f6dc6ab4c56031a358d475192 Mon Sep 17 00:00:00 2001 From: Jorge Esteban Quilcate Otoya Date: Tue, 10 Oct 2023 12:38:25 +0300 Subject: [PATCH] fixup! refactor: fetch and catch parts of segment instead of chunks --- .../io/aiven/kafka/tieredstorage/RemoteStorageManagerTest.java | 2 -- .../aiven/kafka/tieredstorage/fetch/FetchEnumerationTest.java | 1 - .../aiven/kafka/tieredstorage/fetch/cache/FetchCacheTest.java | 1 - 3 files changed, 4 deletions(-) diff --git a/core/src/integration-test/java/io/aiven/kafka/tieredstorage/RemoteStorageManagerTest.java b/core/src/integration-test/java/io/aiven/kafka/tieredstorage/RemoteStorageManagerTest.java index 3859928f1..c10d1bafd 100644 --- a/core/src/integration-test/java/io/aiven/kafka/tieredstorage/RemoteStorageManagerTest.java +++ b/core/src/integration-test/java/io/aiven/kafka/tieredstorage/RemoteStorageManagerTest.java @@ -66,8 +66,6 @@ import io.aiven.kafka.tieredstorage.security.EncryptedDataKey; import io.aiven.kafka.tieredstorage.security.RsaEncryptionProvider; import io.aiven.kafka.tieredstorage.storage.KeyNotFoundException; -import io.aiven.kafka.tieredstorage.storage.StorageBackendException; -import io.aiven.kafka.tieredstorage.transform.KeyNotFoundRuntimeException; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; diff --git a/core/src/test/java/io/aiven/kafka/tieredstorage/fetch/FetchEnumerationTest.java b/core/src/test/java/io/aiven/kafka/tieredstorage/fetch/FetchEnumerationTest.java index 69899518c..25d923edb 100644 --- a/core/src/test/java/io/aiven/kafka/tieredstorage/fetch/FetchEnumerationTest.java +++ b/core/src/test/java/io/aiven/kafka/tieredstorage/fetch/FetchEnumerationTest.java @@ -21,7 +21,6 @@ import org.apache.kafka.server.log.remote.storage.RemoteStorageManager.IndexType; -import io.aiven.kafka.tieredstorage.FetchPart; import io.aiven.kafka.tieredstorage.manifest.SegmentIndexesV1; import io.aiven.kafka.tieredstorage.manifest.SegmentManifest; import io.aiven.kafka.tieredstorage.manifest.SegmentManifestV1; diff --git a/core/src/test/java/io/aiven/kafka/tieredstorage/fetch/cache/FetchCacheTest.java b/core/src/test/java/io/aiven/kafka/tieredstorage/fetch/cache/FetchCacheTest.java index a1ca266c7..dd910d682 100644 --- a/core/src/test/java/io/aiven/kafka/tieredstorage/fetch/cache/FetchCacheTest.java +++ b/core/src/test/java/io/aiven/kafka/tieredstorage/fetch/cache/FetchCacheTest.java @@ -25,7 +25,6 @@ import org.apache.kafka.server.log.remote.storage.RemoteStorageManager.IndexType; -import io.aiven.kafka.tieredstorage.FetchPart; import io.aiven.kafka.tieredstorage.fetch.FetchManager; import io.aiven.kafka.tieredstorage.fetch.FetchPart; import io.aiven.kafka.tieredstorage.fetch.FetchPartKey;