Added delay to reduce cpu time

This commit is contained in:
Brage 2023-07-23 01:47:34 +02:00
parent 0760cf418f
commit 46beb15744

View File

@ -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")