From 46beb157440fbaa257cc280a22777b5871eb7370 Mon Sep 17 00:00:00 2001 From: Brage Date: Sun, 23 Jul 2023 01:47:34 +0200 Subject: [PATCH] Added delay to reduce cpu time --- pyMetadata/app.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/pyMetadata/app.py b/pyMetadata/app.py index a8e88888..7fd85c43 100644 --- a/pyMetadata/app.py +++ b/pyMetadata/app.py @@ -5,6 +5,7 @@ import os import uuid import threading import json +import time from kafka import KafkaConsumer, KafkaProducer from fuzzywuzzy import fuzz from sources.result import DataResult, Metadata @@ -100,6 +101,8 @@ class KafkaConsumerThread(threading.Thread): handler_thread.start() else: logger.info("Ignorert message: key=%s", message.key) + # Introduce a small sleep to reduce CPU usage + time.sleep(1) consumer.close() logger.info("Kafka Consumer stopped")