refactor: Replace RuntimeException with IllegalArgumentException

jim0987795064 · jim0987795064 · commit 4c17b974846a · 2025-08-06T21:04:35.000+02:00
diff --git a/test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/ClusterInstance.java b/test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/ClusterInstance.java
@@ -448,9 +448,9 @@ default int waitUntilLeaderIsElectedOrChangedWithAdmin(Admin admin,
                 " ms since a leader was not elected for partition " + topicPartition);
     }
   
-    default void restartDeadBrokers() throws InterruptedException {
+    default void restartDeadBrokers() throws ExecutionException {
         if (brokers().isEmpty()) {
-            throw new IllegalArgumentException("Must supply at least one server config.");
+            throw new RuntimeException("Must supply at least one server config.");
         }
         brokers().entrySet().forEach(entry -> {
             if (entry.getValue().isShutdown()) {

Original file line number	Diff line number	Diff line change
`@@ -448,9 +448,9 @@ default int waitUntilLeaderIsElectedOrChangedWithAdmin(Admin admin,`
`448`	`448`	`" ms since a leader was not elected for partition " + topicPartition);`
`449`	`449`	`}`
`450`	`450`
`451`		`- default void restartDeadBrokers() throws InterruptedException {`
	`451`	`+ default void restartDeadBrokers() throws ExecutionException {`
`452`	`452`	`if (brokers().isEmpty()) {`
`453`		`- throw new IllegalArgumentException("Must supply at least one server config.");`
	`453`	`+ throw new RuntimeException("Must supply at least one server config.");`
`454`	`454`	`}`
`455`	`455`	`brokers().entrySet().forEach(entry -> {`
`456`	`456`	`if (entry.getValue().isShutdown()) {`