From 7dcf0e386b8b3670b3fda18f7f5c5bd64db72221 Mon Sep 17 00:00:00 2001 From: "Matthias J. Sax" Date: Wed, 18 Dec 2024 21:03:20 -0800 Subject: [PATCH] fix tests --- .../streams/kafka/EmbeddedSingleNodeKafkaCluster.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/test/java/io/confluent/examples/streams/kafka/EmbeddedSingleNodeKafkaCluster.java b/src/test/java/io/confluent/examples/streams/kafka/EmbeddedSingleNodeKafkaCluster.java index c02e26789..442ac4af4 100644 --- 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) {