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

Update

Browse Source
This commit is contained in:
Brage 2023-11-07 02:13:35 +01:00
parent c5b6582c64
commit c59d406493
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
pyMetadata/app.py
View File

@ -78,13 +78,17 @@ class KafkaConsumerThread(threading.Thread):
self.shutdown = threading.Event() self.shutdown = threading.Event()
def run(self): def run(self):
consumer = KafkaConsumer( consumer = None
self.topic, try:
bootstrap_servers=self.bootstrap_servers, consumer = KafkaConsumer(
group_id=self.consumer_group, self.topic,
key_deserializer=lambda x: decode_key(x), bootstrap_servers=self.bootstrap_servers,
value_deserializer=lambda x: decode_value(x) 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") logger.info("Kafka Consumer started")