Delete unused classes (apache#14797)

Reviewers: Mickael Maison <[email protected]>
clolov · Apr 5, 2024 · 55368c2 · 55368c2
1 parent b559c48
commit 55368c2
Show file tree

Hide file tree

Showing 5 changed files with 1 addition and 108 deletions.
diff --git a/core/src/main/scala/kafka/common/InconsistentBrokerIdException.scala b/core/src/main/scala/kafka/common/InconsistentBrokerIdException.scala
diff --git a/core/src/main/scala/kafka/common/InconsistentBrokerMetadataException.scala b/core/src/main/scala/kafka/common/InconsistentBrokerMetadataException.scala
diff --git a/core/src/main/scala/kafka/common/InconsistentClusterIdException.scala b/core/src/main/scala/kafka/common/InconsistentClusterIdException.scala
diff --git a/core/src/main/scala/kafka/common/InconsistentNodeIdException.scala b/core/src/main/scala/kafka/common/InconsistentNodeIdException.scala
diff --git a/core/src/test/scala/unit/kafka/server/ServerGenerateBrokerIdTest.scala b/core/src/test/scala/unit/kafka/server/ServerGenerateBrokerIdTest.scala
@@ -131,11 +131,7 @@ class ServerGenerateBrokerIdTest extends QuorumTestHarness {
     servers = Seq(server1)
     server1.shutdown()
     server1 = new KafkaServer(config2, threadNamePrefix = Option(this.getClass.getName)) // user specified broker id
-    try {
-      server1.startup()
-    } catch {
-      case _: kafka.common.InconsistentBrokerIdException => //success
-    }
+    server1.startup()
     server1.shutdown()
     TestUtils.assertNoNonDaemonThreads(this.getClass.getName)
   }