Create shared/event_bus/kafka_consumer.py

Author: Trojan3877

shared/event_bus/kafka_consumer.py

@@ -0,0 +1,14 @@
+from kafka import KafkaConsumer
+import json
+from shared.config import settings
+
+
+def create_consumer(topic: str):
+    return KafkaConsumer(
+        topic,
+        bootstrap_servers=settings.KAFKA_BOOTSTRAP_SERVERS,
+        value_deserializer=lambda m: json.loads(m.decode("utf-8")),
+        auto_offset_reset="earliest",
+        enable_auto_commit=True,
+        group_id="ride-sharing-group",
+    )