[hotfix][tests] Await broker shutdown during KafkaTestEnvironmentImpl…

…#shutdown
apache · Dec 14, 2021 · df3258c · df3258c
1 parent e7cd468
commit df3258c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...a/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java b/...a/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
@@ -372,6 +372,7 @@ public void shutdown() throws Exception {
         for (KafkaServer broker : brokers) {
             if (broker != null) {
                 broker.shutdown();
+                broker.awaitShutdown();
             }
         }
         brokers.clear();