core --no-cachev

engine/wsgi.py

@@ -0,0 +1,37 @@
+import threading
+from app import create_app
+from app.integrations import KafkaIntegration
+from app.config import settings
+from app.utils.logger import logger
+
+app = create_app()
+kafka = KafkaIntegration()
+
+def start_kafka_consumer(app):
+    with app.app_context():
+        logger.info("Starting Kafka consumer...")
+        while True:
+            try:
+
+                message = kafka.receive_messages(
+                    topics=settings.KAFKA_TOPICS, timeout=settings.KAFKA_TIMEOUT
+                )
+
+                if message:
+                    logger.info(f"Processed message: {message}")
+                else:
+                    logger.info("No message received within timeout")
+
+
+            except Exception as e:
+                logger.error(f"Error while receiving message: {e}")
+
+
+
+if __name__ != "__main__":
+
+    # Expose WSGI app instance for Gunicorn
+    wsgi_app = app
+
+    # Start kafka in a thread
+    threading.Thread(target=start_kafka_consumer, args=(app,), daemon=True).start()