"Fix" WindowsEmbeddedKafkaRule

patschuh · Mar 1, 2023 · 0efa698 · 0efa698
1 parent 56343fe
commit 0efa698
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/src/test/java/kafka/WindowsEmbeddedKafkaRule.java b/src/test/java/kafka/WindowsEmbeddedKafkaRule.java
@@ -1,7 +1,6 @@
 package kafka;
 
 import kafka.server.KafkaServer;
-import kafka.server.NotRunning;
 import org.apache.kafka.common.utils.Utils;
 import org.apache.kafka.test.TestUtils;
 import org.springframework.kafka.test.EmbeddedKafkaBroker;
@@ -63,10 +62,8 @@ public void after() {
     }
 
     private void shutdown(KafkaServer kafkaServer) {
-        if (kafkaServer.brokerState().get().value() != NotRunning.state()) {
             kafkaServer.shutdown();
             kafkaServer.awaitShutdown();
-        }
     }
 
     private void deleteLogDir(KafkaServer kafkaServer) {