diff --git a/client-it/src/test/java/io/streamnative/oxia/client/it/OxiaClientFailFastIT.java b/client-it/src/test/java/io/streamnative/oxia/client/it/OxiaClientFailFastIT.java
index f58c8604..8bd4c891 100644
--- a/client-it/src/test/java/io/streamnative/oxia/client/it/OxiaClientFailFastIT.java
+++ b/client-it/src/test/java/io/streamnative/oxia/client/it/OxiaClientFailFastIT.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client.it;
-
import io.streamnative.oxia.client.OxiaClientBuilder;
import io.streamnative.oxia.client.shard.NamespaceNotFoundException;
import io.streamnative.oxia.testcontainers.OxiaContainer;
diff --git a/client-metrics-api/src/main/java/io/streamnative/oxia/client/metrics/api/Metrics.java b/client-metrics-api/src/main/java/io/streamnative/oxia/client/metrics/api/Metrics.java
index e37dd86a..02045d8f 100644
--- a/client-metrics-api/src/main/java/io/streamnative/oxia/client/metrics/api/Metrics.java
+++ b/client-metrics-api/src/main/java/io/streamnative/oxia/client/metrics/api/Metrics.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client.metrics.api;
-
import java.util.Map;
import lombok.NonNull;
diff --git a/client/pom.xml b/client/pom.xml
index e44bbf7f..fcc574ff 100644
--- a/client/pom.xml
+++ b/client/pom.xml
@@ -31,12 +31,12 @@
3.1.4
- 1.51.0
+ 1.59.0
1.2.2
1.3.2
- 3.21.7
+ 3.25.0
3.5.2
- 1.2.3
+ 1.2.4
0.16
@@ -58,6 +58,11 @@
caffeine
${caffeine.version}
+
+ com.google.protobuf
+ protobuf-java
+ ${protobuf.version}
+
com.salesforce.servicelibs
reactor-grpc-stub
@@ -95,6 +100,11 @@
zero-allocation-hashing
${zah.version}
+
+ io.grpc
+ grpc-inprocess
+ test
+
io.projectreactor
reactor-test
diff --git a/client/src/main/java/io/streamnative/oxia/client/ClientConfig.java b/client/src/main/java/io/streamnative/oxia/client/ClientConfig.java
index 1bbb9478..ce60424a 100644
--- a/client/src/main/java/io/streamnative/oxia/client/ClientConfig.java
+++ b/client/src/main/java/io/streamnative/oxia/client/ClientConfig.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client;
-
import io.streamnative.oxia.client.metrics.api.Metrics;
import java.time.Duration;
import lombok.NonNull;
diff --git a/client/src/main/java/io/streamnative/oxia/client/CompareWithSlash.java b/client/src/main/java/io/streamnative/oxia/client/CompareWithSlash.java
index e50c9540..29c0c610 100644
--- a/client/src/main/java/io/streamnative/oxia/client/CompareWithSlash.java
+++ b/client/src/main/java/io/streamnative/oxia/client/CompareWithSlash.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client;
-
import java.util.Comparator;
import java.util.function.Predicate;
import lombok.NonNull;
diff --git a/client/src/main/java/io/streamnative/oxia/client/CompositeConsumer.java b/client/src/main/java/io/streamnative/oxia/client/CompositeConsumer.java
index 6e7c397b..5a3b0442 100644
--- a/client/src/main/java/io/streamnative/oxia/client/CompositeConsumer.java
+++ b/client/src/main/java/io/streamnative/oxia/client/CompositeConsumer.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client;
-
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.Consumer;
diff --git a/client/src/main/java/io/streamnative/oxia/client/ProtoUtil.java b/client/src/main/java/io/streamnative/oxia/client/ProtoUtil.java
index 3ab2e8bf..4d52d877 100644
--- a/client/src/main/java/io/streamnative/oxia/client/ProtoUtil.java
+++ b/client/src/main/java/io/streamnative/oxia/client/ProtoUtil.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client;
-
import java.nio.ByteBuffer;
public class ProtoUtil {
diff --git a/client/src/main/java/io/streamnative/oxia/client/SyncOxiaClientImpl.java b/client/src/main/java/io/streamnative/oxia/client/SyncOxiaClientImpl.java
index 8e7bde97..63daacd3 100644
--- a/client/src/main/java/io/streamnative/oxia/client/SyncOxiaClientImpl.java
+++ b/client/src/main/java/io/streamnative/oxia/client/SyncOxiaClientImpl.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client;
-
import io.streamnative.oxia.client.api.AsyncOxiaClient;
import io.streamnative.oxia.client.api.DeleteOption;
import io.streamnative.oxia.client.api.GetResult;
diff --git a/client/src/main/java/io/streamnative/oxia/client/api/AsyncOxiaClient.java b/client/src/main/java/io/streamnative/oxia/client/api/AsyncOxiaClient.java
index 4d934bdc..f090b5f8 100644
--- a/client/src/main/java/io/streamnative/oxia/client/api/AsyncOxiaClient.java
+++ b/client/src/main/java/io/streamnative/oxia/client/api/AsyncOxiaClient.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client.api;
-
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.function.Consumer;
diff --git a/client/src/main/java/io/streamnative/oxia/client/api/GetResult.java b/client/src/main/java/io/streamnative/oxia/client/api/GetResult.java
index 506fa554..6310660d 100644
--- a/client/src/main/java/io/streamnative/oxia/client/api/GetResult.java
+++ b/client/src/main/java/io/streamnative/oxia/client/api/GetResult.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client.api;
-
import io.streamnative.oxia.proto.GetResponse;
import lombok.NonNull;
import lombok.Value;
@@ -25,6 +24,7 @@
public class GetResult {
/** The value associated with the key specified in the call. */
byte @NonNull [] value;
+
/** Metadata for the record associated with the key specified in the call. */
@NonNull Version version;
diff --git a/client/src/main/java/io/streamnative/oxia/client/api/KeyAlreadyExistsException.java b/client/src/main/java/io/streamnative/oxia/client/api/KeyAlreadyExistsException.java
index c71774e8..b84ffd91 100644
--- a/client/src/main/java/io/streamnative/oxia/client/api/KeyAlreadyExistsException.java
+++ b/client/src/main/java/io/streamnative/oxia/client/api/KeyAlreadyExistsException.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client.api;
-
import lombok.Getter;
import lombok.NonNull;
diff --git a/client/src/main/java/io/streamnative/oxia/client/api/Notification.java b/client/src/main/java/io/streamnative/oxia/client/api/Notification.java
index 0c6ad81b..a0eb55f6 100644
--- a/client/src/main/java/io/streamnative/oxia/client/api/Notification.java
+++ b/client/src/main/java/io/streamnative/oxia/client/api/Notification.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client.api;
-
import lombok.NonNull;
/** A notification from an Oxia server indicating a change to a record associated with a key. */
diff --git a/client/src/main/java/io/streamnative/oxia/client/api/PutResult.java b/client/src/main/java/io/streamnative/oxia/client/api/PutResult.java
index c6a69548..dfb2f5c4 100644
--- a/client/src/main/java/io/streamnative/oxia/client/api/PutResult.java
+++ b/client/src/main/java/io/streamnative/oxia/client/api/PutResult.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client.api;
-
import io.streamnative.oxia.proto.PutResponse;
import lombok.NonNull;
diff --git a/client/src/main/java/io/streamnative/oxia/client/api/SyncOxiaClient.java b/client/src/main/java/io/streamnative/oxia/client/api/SyncOxiaClient.java
index 925a0157..921fe80a 100644
--- a/client/src/main/java/io/streamnative/oxia/client/api/SyncOxiaClient.java
+++ b/client/src/main/java/io/streamnative/oxia/client/api/SyncOxiaClient.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client.api;
-
import java.util.List;
import java.util.function.Consumer;
import lombok.NonNull;
diff --git a/client/src/main/java/io/streamnative/oxia/client/api/UnexpectedVersionIdException.java b/client/src/main/java/io/streamnative/oxia/client/api/UnexpectedVersionIdException.java
index 784aba27..3bef0a07 100644
--- a/client/src/main/java/io/streamnative/oxia/client/api/UnexpectedVersionIdException.java
+++ b/client/src/main/java/io/streamnative/oxia/client/api/UnexpectedVersionIdException.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client.api;
-
import lombok.Getter;
import lombok.NonNull;
diff --git a/client/src/main/java/io/streamnative/oxia/client/api/Version.java b/client/src/main/java/io/streamnative/oxia/client/api/Version.java
index 0845686d..fdc2a82c 100644
--- a/client/src/main/java/io/streamnative/oxia/client/api/Version.java
+++ b/client/src/main/java/io/streamnative/oxia/client/api/Version.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client.api;
-
import java.util.Optional;
import lombok.NonNull;
diff --git a/client/src/main/java/io/streamnative/oxia/client/grpc/CustomStatusCode.java b/client/src/main/java/io/streamnative/oxia/client/grpc/CustomStatusCode.java
index 0755ee4e..600a22ff 100644
--- a/client/src/main/java/io/streamnative/oxia/client/grpc/CustomStatusCode.java
+++ b/client/src/main/java/io/streamnative/oxia/client/grpc/CustomStatusCode.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client.grpc;
-
import java.util.Objects;
import lombok.NonNull;
diff --git a/client/src/main/java/io/streamnative/oxia/client/grpc/ServiceAddress.java b/client/src/main/java/io/streamnative/oxia/client/grpc/ServiceAddress.java
index c086288c..7e6d9f00 100644
--- a/client/src/main/java/io/streamnative/oxia/client/grpc/ServiceAddress.java
+++ b/client/src/main/java/io/streamnative/oxia/client/grpc/ServiceAddress.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client.grpc;
-
import lombok.NonNull;
import lombok.SneakyThrows;
diff --git a/client/src/main/java/io/streamnative/oxia/client/shard/NamespaceNotFoundException.java b/client/src/main/java/io/streamnative/oxia/client/shard/NamespaceNotFoundException.java
index 47c57565..cd6a2ecf 100644
--- a/client/src/main/java/io/streamnative/oxia/client/shard/NamespaceNotFoundException.java
+++ b/client/src/main/java/io/streamnative/oxia/client/shard/NamespaceNotFoundException.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client.shard;
-
import lombok.Getter;
import lombok.NonNull;
diff --git a/client/src/main/java/io/streamnative/oxia/client/shard/NoShardAvailableException.java b/client/src/main/java/io/streamnative/oxia/client/shard/NoShardAvailableException.java
index 2693f67a..02e84069 100644
--- a/client/src/main/java/io/streamnative/oxia/client/shard/NoShardAvailableException.java
+++ b/client/src/main/java/io/streamnative/oxia/client/shard/NoShardAvailableException.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client.shard;
-
import lombok.Getter;
import lombok.NonNull;
@@ -34,6 +33,7 @@ public NoShardAvailableException(@NonNull String key) {
this.key = key;
this.shardId = null;
}
+
/**
* Creates an instance of the exception.
*
diff --git a/client/src/main/java/io/streamnative/oxia/client/shard/ShardStrategy.java b/client/src/main/java/io/streamnative/oxia/client/shard/ShardStrategy.java
index e2f377f1..8f11912c 100644
--- a/client/src/main/java/io/streamnative/oxia/client/shard/ShardStrategy.java
+++ b/client/src/main/java/io/streamnative/oxia/client/shard/ShardStrategy.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client.shard;
-
import java.util.function.Predicate;
import lombok.NonNull;
diff --git a/etc/findbugsExclude.xml b/etc/findbugsExclude.xml
index 46317434..c6e98707 100644
--- a/etc/findbugsExclude.xml
+++ b/etc/findbugsExclude.xml
@@ -28,4 +28,8 @@
+
+
+
+
diff --git a/perf/pom.xml b/perf/pom.xml
index 9e68ac85..43ba67ab 100644
--- a/perf/pom.xml
+++ b/perf/pom.xml
@@ -83,6 +83,10 @@
+
+
+ io.streamnative.oxia.client.perf.PerfClient
+
diff --git a/perf/src/main/java/io/streamnative/oxia/client/perf/PerfArguments.java b/perf/src/main/java/io/streamnative/oxia/client/perf/PerfArguments.java
index f6c7ee1b..ec72c55d 100644
--- a/perf/src/main/java/io/streamnative/oxia/client/perf/PerfArguments.java
+++ b/perf/src/main/java/io/streamnative/oxia/client/perf/PerfArguments.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.oxia.client.perf;
-
import com.beust.jcommander.Parameter;
import com.beust.jcommander.Parameters;
import io.streamnative.oxia.client.OxiaClientBuilder;
diff --git a/pom.xml b/pom.xml
index 34abca03..210bd854 100644
--- a/pom.xml
+++ b/pom.xml
@@ -66,22 +66,22 @@
3.24.1
3.0.0
- 10.3.3
- 1.18.24
- 2.0.5
+ 10.12.5
+ 1.18.30
+ 1.7.32
5.9.2
4.11.0
1.23.1
1.17.6
- 3.2.0
+ 3.3.1
0.8.8
4.1
3.10.1
3.1.0
3.0.0-M7
- 4.7.2.0
- 2.25.0
+ 4.8.1.0
+ 2.39.0
diff --git a/pulsar-metadatastore-oxia/pom.xml b/pulsar-metadatastore-oxia/pom.xml
index dc220379..7b2cdca7 100644
--- a/pulsar-metadatastore-oxia/pom.xml
+++ b/pulsar-metadatastore-oxia/pom.xml
@@ -50,8 +50,8 @@
3.1.0
3.4.1
3.0.0-M7
- 4.7.2.0
- 2.25.0
+ 4.8.1.0
+ 2.39.0
diff --git a/pulsar-metadatastore-oxia/src/main/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStore.java b/pulsar-metadatastore-oxia/src/main/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStore.java
index befc67dd..7466c019 100644
--- a/pulsar-metadatastore-oxia/src/main/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStore.java
+++ b/pulsar-metadatastore-oxia/src/main/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStore.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia;
-
import io.streamnative.oxia.client.OxiaClientBuilder;
import io.streamnative.oxia.client.api.AsyncOxiaClient;
import io.streamnative.oxia.client.api.DeleteOption;
diff --git a/pulsar-metadatastore-oxia/src/main/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreProvider.java b/pulsar-metadatastore-oxia/src/main/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreProvider.java
index 0395caed..41ed9a5c 100644
--- a/pulsar-metadatastore-oxia/src/main/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreProvider.java
+++ b/pulsar-metadatastore-oxia/src/main/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreProvider.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia;
-
import lombok.NonNull;
import org.apache.commons.lang3.tuple.Pair;
import org.apache.pulsar.metadata.api.MetadataStore;
diff --git a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaCounterTest.java b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaCounterTest.java
index 428c9745..ccb655da 100644
--- a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaCounterTest.java
+++ b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaCounterTest.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia;
-
import io.streamnative.oxia.testcontainers.OxiaContainer;
import lombok.Getter;
import lombok.Setter;
diff --git a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaLeaderElectionTest.java b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaLeaderElectionTest.java
index 73ae0a5d..1653ef89 100644
--- a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaLeaderElectionTest.java
+++ b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaLeaderElectionTest.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia;
-
import io.streamnative.oxia.testcontainers.OxiaContainer;
import lombok.Getter;
import lombok.Setter;
diff --git a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaLockManagerTest.java b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaLockManagerTest.java
index 2dda593f..57f01cf3 100644
--- a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaLockManagerTest.java
+++ b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaLockManagerTest.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia;
-
import io.streamnative.oxia.testcontainers.OxiaContainer;
import java.util.function.Supplier;
import lombok.Getter;
diff --git a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataCacheTest.java b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataCacheTest.java
index e3f3a329..6df643a6 100644
--- a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataCacheTest.java
+++ b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataCacheTest.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia;
-
import io.streamnative.oxia.testcontainers.OxiaContainer;
import java.util.function.Supplier;
import lombok.Getter;
diff --git a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreBatchingTest.java b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreBatchingTest.java
index ef3469d7..c22e0888 100644
--- a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreBatchingTest.java
+++ b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreBatchingTest.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia;
-
import io.streamnative.oxia.testcontainers.OxiaContainer;
import java.util.function.Supplier;
import lombok.Getter;
diff --git a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreExtendedTest.java b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreExtendedTest.java
index acd03b82..a44bc4bc 100644
--- a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreExtendedTest.java
+++ b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreExtendedTest.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia;
-
import io.streamnative.oxia.testcontainers.OxiaContainer;
import lombok.Getter;
import lombok.Setter;
diff --git a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreProviderTest.java b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreProviderTest.java
index 62ceed94..cdd10996 100644
--- a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreProviderTest.java
+++ b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreProviderTest.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia;
-
import io.streamnative.oxia.testcontainers.OxiaContainer;
import lombok.Getter;
import lombok.Setter;
diff --git a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreTest.java b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreTest.java
index ce216eda..2ee185b3 100644
--- a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreTest.java
+++ b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStoreTest.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia;
-
import io.streamnative.oxia.testcontainers.OxiaContainer;
import java.util.function.Supplier;
import lombok.Getter;
diff --git a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaTestBase.java b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaTestBase.java
index 0cbf3de5..5ccd44cb 100644
--- a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaTestBase.java
+++ b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/OxiaTestBase.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia;
-
import io.streamnative.oxia.testcontainers.OxiaContainer;
import java.util.function.Supplier;
import org.apache.pulsar.metadata.impl.MetadataStoreFactoryImpl;
diff --git a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaEndToEndTest.java b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaEndToEndTest.java
index a78106eb..37a955b0 100644
--- a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaEndToEndTest.java
+++ b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaEndToEndTest.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia.bookkeeper;
-
import io.streamnative.oxia.testcontainers.OxiaContainer;
import io.streamnative.pulsarmetadatastoreoxia.OxiaTestBase;
import lombok.Getter;
diff --git a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaLedgerManagerIteratorTest.java b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaLedgerManagerIteratorTest.java
index 81c9d7b2..5c4c2dc3 100644
--- a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaLedgerManagerIteratorTest.java
+++ b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaLedgerManagerIteratorTest.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia.bookkeeper;
-
import io.streamnative.oxia.testcontainers.OxiaContainer;
import io.streamnative.pulsarmetadatastoreoxia.OxiaTestBase;
import lombok.Getter;
diff --git a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaLedgerUnderreplicationManagerTest.java b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaLedgerUnderreplicationManagerTest.java
index 28631a79..b5def9c6 100644
--- a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaLedgerUnderreplicationManagerTest.java
+++ b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaLedgerUnderreplicationManagerTest.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia.bookkeeper;
-
import io.streamnative.oxia.testcontainers.OxiaContainer;
import io.streamnative.pulsarmetadatastoreoxia.OxiaTestBase;
import lombok.Getter;
diff --git a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarLayoutManagerTest.java b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarLayoutManagerTest.java
index 7c52c435..95c93310 100644
--- a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarLayoutManagerTest.java
+++ b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarLayoutManagerTest.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia.bookkeeper;
-
import io.streamnative.oxia.testcontainers.OxiaContainer;
import io.streamnative.pulsarmetadatastoreoxia.OxiaTestBase;
import lombok.Getter;
diff --git a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarLedgerAuditorManagerTest.java b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarLedgerAuditorManagerTest.java
index b4b0acce..e1739b4d 100644
--- a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarLedgerAuditorManagerTest.java
+++ b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarLedgerAuditorManagerTest.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia.bookkeeper;
-
import io.streamnative.oxia.testcontainers.OxiaContainer;
import io.streamnative.pulsarmetadatastoreoxia.OxiaTestBase;
import lombok.Getter;
diff --git a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarLedgerIdGeneratorTest.java b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarLedgerIdGeneratorTest.java
index 417b6ccc..9ad95532 100644
--- a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarLedgerIdGeneratorTest.java
+++ b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarLedgerIdGeneratorTest.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia.bookkeeper;
-
import io.streamnative.oxia.testcontainers.OxiaContainer;
import io.streamnative.pulsarmetadatastoreoxia.OxiaTestBase;
import lombok.Getter;
diff --git a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarRegistrationClientTest.java b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarRegistrationClientTest.java
index 14015274..0e81f0b7 100644
--- a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarRegistrationClientTest.java
+++ b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarRegistrationClientTest.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia.bookkeeper;
-
import io.streamnative.oxia.testcontainers.OxiaContainer;
import io.streamnative.pulsarmetadatastoreoxia.OxiaTestBase;
import lombok.Getter;
diff --git a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarRegistrationManagerTest.java b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarRegistrationManagerTest.java
index 7439d037..3a339266 100644
--- a/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarRegistrationManagerTest.java
+++ b/pulsar-metadatastore-oxia/src/test/java/io/streamnative/pulsarmetadatastoreoxia/bookkeeper/OxiaPulsarRegistrationManagerTest.java
@@ -15,7 +15,6 @@
*/
package io.streamnative.pulsarmetadatastoreoxia.bookkeeper;
-
import io.streamnative.oxia.testcontainers.OxiaContainer;
import io.streamnative.pulsarmetadatastoreoxia.OxiaTestBase;
import lombok.Getter;