diff --git a/pyMetadata/app.py b/pyMetadata/app.py index 9cf15104..1c50f30f 100644 --- a/pyMetadata/app.py +++ b/pyMetadata/app.py @@ -78,13 +78,17 @@ class KafkaConsumerThread(threading.Thread): self.shutdown = threading.Event() def run(self): - consumer = KafkaConsumer( - self.topic, - bootstrap_servers=self.bootstrap_servers, - group_id=self.consumer_group, - key_deserializer=lambda x: decode_key(x), - value_deserializer=lambda x: decode_value(x) - ) + consumer = None + try: + consumer = KafkaConsumer( + self.topic, + bootstrap_servers=self.bootstrap_servers, + group_id=self.consumer_group, + key_deserializer=lambda x: decode_key(x), + value_deserializer=lambda x: decode_value(x) + ) + except: + self.stop() logger.info("Kafka Consumer started")