From 53a39b07dd216cc1e12b341200a5f7cd5d63a3f6 Mon Sep 17 00:00:00 2001
From: Daniel Rosel <daniel@alves.world>
Date: Thu, 13 Nov 2025 18:27:36 +0100
Subject: [PATCH] prod kafka server logging

---
 backend/server/app.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/backend/server/app.py b/backend/server/app.py
index 0443250..c91a88c 100644
--- a/backend/server/app.py
+++ b/backend/server/app.py
@@ -22,16 +22,18 @@ def get_producer() -> KafkaProducer:
         host = os.getenv('KAFKA_HOST', 'localhost')
         port = os.getenv('KAFKA_PORT', '9092')
         broker = f'{host}:{port}' if port else host
+        print(f"[KAFKA_INIT] Connecting to broker: {broker}")
         _producer = KafkaProducer(
             bootstrap_servers=[broker],
             value_serializer=lambda v: json.dumps(v).encode('utf-8'),
             key_serializer=lambda k: k.encode('utf-8') if k else None,
-            acks=1,  # wait for leader ack only
+            acks=1,
             retries=3,
             max_in_flight_requests_per_connection=5,
             request_timeout_ms=30000,
             api_version_auto_timeout_ms=10000,
         )
+        print(f"[KAFKA_INIT] Producer created successfully")
     return _producer
 
 class EventPayload(BaseModel):