[kafka] branch trunk updated: MINOR: fix flaky ZkMigrationIntegrationTest.testNewAndChangedTopicsInDualWrite (#13902)

[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 12005484af6 MINOR: fix flaky 
ZkMigrationIntegrationTest.testNewAndChangedTopicsInDualWrite (#13902)
12005484af6 is described below

commit 12005484af625a65a8068e021bbf448f7aa59d23
Author: Chia-Ping Tsai <chia7...@gmail.com>
AuthorDate: Wed Jun 28 22:45:26 2023 +0800

    MINOR: fix flaky 
ZkMigrationIntegrationTest.testNewAndChangedTopicsInDualWrite (#13902)
    
    Reviewers: David Arthur <mum...@gmail.com>
---
 .../test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala 
b/core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala
index fc5da56721f..819fcba0908 100644
--- a/core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala
+++ b/core/src/test/scala/integration/kafka/zk/ZkMigrationIntegrationTest.scala
@@ -501,8 +501,7 @@ class ZkMigrationIntegrationTest {
       // Verify the changes seen in Zk.
       verifyTopicPartitionMetadata(topicName, existingPartitions ++ Seq(new 
TopicPartition(topicName, 2)), zkClient)
     } finally {
-      zkCluster.stop()
-      kraftCluster.close()
+      shutdownInSequence(zkCluster, kraftCluster)
     }
   }