add repeated test

apache · Sep 10, 2024 · 01399c1 · 01399c1
1 parent a4802b0
commit 01399c1
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/core/src/test/scala/integration/kafka/zk/ZkMigrationFailoverTest.scala b/core/src/test/scala/integration/kafka/zk/ZkMigrationFailoverTest.scala
@@ -33,8 +33,8 @@ import org.apache.kafka.security.PasswordEncoder
 import org.apache.kafka.server.common.{ApiMessageAndVersion, MetadataVersion}
 import org.apache.kafka.server.fault.FaultHandler
 import org.apache.zookeeper.client.ZKClientConfig
-import org.junit.jupiter.api.Assertions.{assertTrue, assertEquals, fail}
-import org.junit.jupiter.api.Test
+import org.junit.jupiter.api.Assertions.{assertEquals, assertTrue, fail}
+import org.junit.jupiter.api.RepeatedTest
 
 import java.util
 import java.util.concurrent.{CompletableFuture, TimeUnit}
@@ -135,7 +135,7 @@ class ZkMigrationFailoverTest extends Logging {
     future.get(10, TimeUnit.SECONDS)
   }
 
-  @Test
+  @RepeatedTest(10)
   def testControllerFailoverZkRace(): Unit = {
     val zookeeper = new EmbeddedZookeeper()
     var zkClient: KafkaZkClient = null
@@ -288,7 +288,7 @@ class ZkMigrationFailoverTest extends Logging {
     }
   }
 
-  @Test
+  @RepeatedTest(10)
   def testDriverSkipsEventsFromOlderEpoch(): Unit = {
     val zookeeper = new EmbeddedZookeeper()
     var zkClient: KafkaZkClient = null