diff --git a/pyMetadata/app.py b/pyMetadata/app.py
index 1c50f30f..46736d74 100644
--- a/pyMetadata/app.py
+++ b/pyMetadata/app.py
@@ -89,6 +89,7 @@ class KafkaConsumerThread(threading.Thread):
             )
         except:
             self.stop()
+            return
 
         logger.info("Kafka Consumer started")