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) {