iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update python

Browse Source
This commit is contained in:
Brage 2023-11-07 02:37:33 +01:00
parent d866038826
commit b81094f90e
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pyMetadata/app.py
View File

@ -87,12 +87,14 @@ class KafkaConsumerThread(threading.Thread):
key_deserializer=lambda x: decode_key(x), key_deserializer=lambda x: decode_key(x),
value_deserializer=lambda x: decode_value(x) value_deserializer=lambda x: decode_value(x)
) )
except:
self.stop()
return
logger.info("Kafka Consumer started") logger.info("Kafka Consumer started")
except:
logger.exception("Kafka Consumer failed to start")
self.stop()
sys.exit(1)
while not self.shutdown.is_set(): while not self.shutdown.is_set():
for message in consumer: for message in consumer:
if self.shutdown.is_set(): if self.shutdown.is_set():