Updated plugins to work with Java 21

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;

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;
 

client/pom.xml

@@ -31,12 +31,12 @@
 
     <properties>
         <caffeine.version>3.1.4</caffeine.version>
-        <grpc.version>1.51.0</grpc.version>
+        <grpc.version>1.59.0</grpc.version>
         <grpc-test.version>1.2.2</grpc-test.version>
         <javax.annotation.version>1.3.2</javax.annotation.version>
-        <protobuf.version>3.21.7</protobuf.version>
+        <protobuf.version>3.25.0</protobuf.version>
         <reactor.version>3.5.2</reactor.version>
-        <reactor-grpc.version>1.2.3</reactor-grpc.version>
+        <reactor-grpc.version>1.2.4</reactor-grpc.version>
         <zah.version>0.16</zah.version>
     </properties>
 
@@ -58,6 +58,11 @@
             <artifactId>caffeine</artifactId>
             <version>${caffeine.version}</version>
         </dependency>
+        <dependency>
+            <groupId>com.google.protobuf</groupId>
+            <artifactId>protobuf-java</artifactId>
+            <version>${protobuf.version}</version>
+        </dependency>
         <dependency>
             <groupId>com.salesforce.servicelibs</groupId>
             <artifactId>reactor-grpc-stub</artifactId>
@@ -95,6 +100,11 @@
             <artifactId>zero-allocation-hashing</artifactId>
             <version>${zah.version}</version>
         </dependency>
+        <dependency>
+            <groupId>io.grpc</groupId>
+            <artifactId>grpc-inprocess</artifactId>
+            <scope>test</scope>
+        </dependency>
         <dependency>
             <groupId>io.projectreactor</groupId>
             <artifactId>reactor-test</artifactId>

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;

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;

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;

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 {

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;

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;

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;
 

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;
 

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. */

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;
 

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;

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;
 

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;
 

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;
 

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;
 

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;
 

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.
      *

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;
 

etc/findbugsExclude.xml

@@ -28,4 +28,8 @@
     <Class name="io.streamnative.oxia.client.OxiaClientBuilder" />
     <Bug pattern="URF_UNREAD_FIELD" />
   </Match>
+  <Match>
+    <Package name="io.streamnative.oxia.client" />
+    <Bug pattern="CT_CONSTRUCTOR_THROW" />
+  </Match>
 </FindBugsFilter>

perf/pom.xml

@@ -83,6 +83,10 @@
                             </filters>
                             <transformers>
                                 <transformer implementation="org.apache.maven.plugins.shade.resource.ApacheLicenseResourceTransformer"/>
+                                <transformer implementation="org.apache.maven.plugins.shade.resource.ServicesResourceTransformer"/>
+                                <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
+                                    <mainClass>io.streamnative.oxia.client.perf.PerfClient</mainClass>
+                                </transformer>
                             </transformers>
                         </configuration>
                     </execution>

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;

pom.xml

@@ -66,22 +66,22 @@
 
         <assertj.version>3.24.1</assertj.version>
         <awaitility.version>3.0.0</awaitility.version>
-        <checkstyle.version>10.3.3</checkstyle.version>
-        <lombok.version>1.18.24</lombok.version>
-        <slf4j.version>2.0.5</slf4j.version>
+        <checkstyle.version>10.12.5</checkstyle.version>
+        <lombok.version>1.18.30</lombok.version>
+        <slf4j.version>1.7.32</slf4j.version>
         <junit.jupiter.version>5.9.2</junit.jupiter.version>
         <mockito.junit.jupiter.version>4.11.0</mockito.junit.jupiter.version>
         <opentelemetry.version>1.23.1</opentelemetry.version>
         <testcontainers.version>1.17.6</testcontainers.version>
 
-        <checkstyle.plugin.version>3.2.0</checkstyle.plugin.version>
+        <checkstyle.plugin.version>3.3.1</checkstyle.plugin.version>
         <jacoco.plugin.version>0.8.8</jacoco.plugin.version>
         <license.plugin.version>4.1</license.plugin.version>
         <maven.compiler.plugin.version>3.10.1</maven.compiler.plugin.version>
         <maven.enforcer.plugin.version>3.1.0</maven.enforcer.plugin.version>
         <maven.surefire.plugin.version>3.0.0-M7</maven.surefire.plugin.version>
-        <spotbugs.plugin.version>4.7.2.0</spotbugs.plugin.version>
-        <spotless.plugin.version>2.25.0</spotless.plugin.version>
+        <spotbugs.plugin.version>4.8.1.0</spotbugs.plugin.version>
+        <spotless.plugin.version>2.39.0</spotless.plugin.version>
     </properties>
 
     <dependencyManagement>

pulsar-metadatastore-oxia/pom.xml

@@ -50,8 +50,8 @@
         <maven.enforcer.plugin.version>3.1.0</maven.enforcer.plugin.version>
         <maven.shade.plugin.version>3.4.1</maven.shade.plugin.version>
         <maven.surefire.plugin.version>3.0.0-M7</maven.surefire.plugin.version>
-        <spotbugs.plugin.version>4.7.2.0</spotbugs.plugin.version>
-        <spotless.plugin.version>2.25.0</spotless.plugin.version>
+        <spotbugs.plugin.version>4.8.1.0</spotbugs.plugin.version>
+        <spotless.plugin.version>2.39.0</spotless.plugin.version>
     </properties>
 
     <dependencies>

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;

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;

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;

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;

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;

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;

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;

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;

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;

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;

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;

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;

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;

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;