fix: change kafka dependency for release issues

aequitas-aod · Dec 11, 2024 · 827ae0f · 827ae0f
1 parent 08ac3b6
commit 827ae0f
Show file tree

Hide file tree

Showing 4 changed files with 113 additions and 81 deletions.
diff --git a/infrastructure/events/consumer.py b/infrastructure/events/consumer.py
@@ -2,7 +2,7 @@
 from multiprocessing import Process
 from typing import List, Dict
 
-from kafka3 import KafkaConsumer
+from kafka import KafkaConsumer
 from typing_extensions import Callable
 
 from infrastructure.events import KafkaBroker, get_brokers_from_env

diff --git a/infrastructure/events/producer.py b/infrastructure/events/producer.py
@@ -1,7 +1,7 @@
 import json
 from typing import List
 
-from kafka3 import KafkaProducer
+from kafka import KafkaProducer
 
 from infrastructure.events import KafkaBroker, get_brokers_from_env
 from infrastructure.ws.utils import logger