fix tests

confluentinc · Dec 23, 2024 · 16607c9 · 16607c9
1 parent 83c4ae1
commit 16607c9
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/test/java/io/confluent/examples/streams/kafka/EmbeddedSingleNodeKafkaCluster.java b/src/test/java/io/confluent/examples/streams/kafka/EmbeddedSingleNodeKafkaCluster.java
@@ -132,6 +132,10 @@ protected void after() {
    * Stops the cluster.
    */
   public void stop() {
+    if (!running) {
+      log.info("Confluent is already stopped");
+      return;
+    }
     log.info("Stopping Confluent");
     try {
       if (schemaRegistry != null) {