From b81094f90e892d6c1cbc0eb31d49720b72d1f9f7 Mon Sep 17 00:00:00 2001 From: Brage Date: Tue, 7 Nov 2023 02:37:33 +0100 Subject: [PATCH] Update python --- pyMetadata/app.py | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/pyMetadata/app.py b/pyMetadata/app.py index 46736d74..899dbe55 100644 --- a/pyMetadata/app.py +++ b/pyMetadata/app.py @@ -87,11 +87,13 @@ class KafkaConsumerThread(threading.Thread): key_deserializer=lambda x: decode_key(x), value_deserializer=lambda x: decode_value(x) ) - except: - self.stop() - return + logger.info("Kafka Consumer started") + + except: + logger.exception("Kafka Consumer failed to start") + self.stop() + sys.exit(1) - logger.info("Kafka Consumer started") while not self.shutdown.is_set(): for message in consumer: