(kafka) branch KAFKA-17506-flaky-ZkMigrationFailoverTest updated: add repeated test

[davidarthur]

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

davidarthur pushed a commit to branch KAFKA-17506-flaky-ZkMigrationFailoverTest
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to 
refs/heads/KAFKA-17506-flaky-ZkMigrationFailoverTest by this push:
     new 01399c16387 add repeated test
01399c16387 is described below

commit 01399c163871d3c9df3c063ced4b6069ae746c35
Author: David Arthur <mum...@gmail.com>
AuthorDate: Mon Sep 9 20:46:22 2024 -0400

    add repeated test
---
 .../test/scala/integration/kafka/zk/ZkMigrationFailoverTest.scala | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/core/src/test/scala/integration/kafka/zk/ZkMigrationFailoverTest.scala 
b/core/src/test/scala/integration/kafka/zk/ZkMigrationFailoverTest.scala
index 10c9df4577f..1a5ac8b57ae 100644
--- 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