(kafka) branch trunk updated: KAFKA-18148 Remove exceptions from method signatures in Persister (#18064)

[chia7712]

This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 22f4c4a1733 KAFKA-18148 Remove exceptions from method signatures in 
Persister (#18064)
22f4c4a1733 is described below

commit 22f4c4a173368785ce5e65c97043b8bc579a559c
Author: msureshpro <67648448+msuresh...@users.noreply.github.com>
AuthorDate: Fri Dec 6 13:03:16 2024 +0530

    KAFKA-18148 Remove exceptions from method signatures in Persister (#18064)
    
    Reviewers: Abhinav Dixit <adi...@confluent.io>, Chia-Ping Tsai 
<chia7...@gmail.com>
---
 .../apache/kafka/server/share/persister/DefaultStatePersister.java  | 6 +++---
 .../java/org/apache/kafka/server/share/persister/Persister.java     | 6 +++---
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/share/src/main/java/org/apache/kafka/server/share/persister/DefaultStatePersister.java
 
b/share/src/main/java/org/apache/kafka/server/share/persister/DefaultStatePersister.java
index 07ac3eab116..01004a3d799 100644
--- 
a/share/src/main/java/org/apache/kafka/server/share/persister/DefaultStatePersister.java
+++ 
b/share/src/main/java/org/apache/kafka/server/share/persister/DefaultStatePersister.java
@@ -67,7 +67,7 @@ public class DefaultStatePersister implements Persister {
      * @param request InitializeShareGroupStateParameters
      * @return A completable future of InitializeShareGroupStateResult
      */
-    public CompletableFuture<InitializeShareGroupStateResult> 
initializeState(InitializeShareGroupStateParameters request) throws 
IllegalArgumentException {
+    public CompletableFuture<InitializeShareGroupStateResult> 
initializeState(InitializeShareGroupStateParameters request) {
         throw new RuntimeException("not implemented");
     }
 
@@ -276,7 +276,7 @@ public class DefaultStatePersister implements Persister {
      * @param request DeleteShareGroupStateParameters
      * @return A completable future of DeleteShareGroupStateResult
      */
-    public CompletableFuture<DeleteShareGroupStateResult> 
deleteState(DeleteShareGroupStateParameters request) throws 
IllegalArgumentException {
+    public CompletableFuture<DeleteShareGroupStateResult> 
deleteState(DeleteShareGroupStateParameters request) {
         throw new RuntimeException("not implemented");
     }
 
@@ -287,7 +287,7 @@ public class DefaultStatePersister implements Persister {
      * @param request ReadShareGroupStateSummaryParameters
      * @return A completable future of  ReadShareGroupStateSummaryResult
      */
-    public CompletableFuture<ReadShareGroupStateSummaryResult> 
readSummary(ReadShareGroupStateSummaryParameters request) throws 
IllegalArgumentException {
+    public CompletableFuture<ReadShareGroupStateSummaryResult> 
readSummary(ReadShareGroupStateSummaryParameters request) {
         throw new RuntimeException("not implemented");
     }
 
diff --git 
a/share/src/main/java/org/apache/kafka/server/share/persister/Persister.java 
b/share/src/main/java/org/apache/kafka/server/share/persister/Persister.java
index ac0a7955a70..fddb01154bd 100644
--- a/share/src/main/java/org/apache/kafka/server/share/persister/Persister.java
+++ b/share/src/main/java/org/apache/kafka/server/share/persister/Persister.java
@@ -32,7 +32,7 @@ public interface Persister {
      * @param request Request parameters
      * @return A {@link CompletableFuture} that completes with the result.
      */
-    CompletableFuture<InitializeShareGroupStateResult> 
initializeState(InitializeShareGroupStateParameters request) throws 
IllegalArgumentException;
+    CompletableFuture<InitializeShareGroupStateResult> 
initializeState(InitializeShareGroupStateParameters request);
 
     /**
      * Read share-partition state.
@@ -56,7 +56,7 @@ public interface Persister {
      * @param request Request parameters
      * @return A {@link CompletableFuture} that completes with the result.
      */
-    CompletableFuture<DeleteShareGroupStateResult> 
deleteState(DeleteShareGroupStateParameters request) throws 
IllegalArgumentException;
+    CompletableFuture<DeleteShareGroupStateResult> 
deleteState(DeleteShareGroupStateParameters request);
 
     /**
      * Read the offset information from share-partition state.
@@ -64,7 +64,7 @@ public interface Persister {
      * @param request Request parameters
      * @return A {@link CompletableFuture} that completes with the result.
      */
-    CompletableFuture<ReadShareGroupStateSummaryResult> 
readSummary(ReadShareGroupStateSummaryParameters request) throws 
IllegalArgumentException;
+    CompletableFuture<ReadShareGroupStateSummaryResult> 
readSummary(ReadShareGroupStateSummaryParameters request);
 
     /**
      * Perform cleanup and interrupt any threads