Update utils/main.py

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

Author: h00dieB0y

utils/main.py

@@ -45,7 +45,10 @@
                 logger.warning("Failed to fetch story %s: %s", story_id, e)
                 continue
 
-        producer.flush()
+        try:
+            producer.flush()
+        except Exception as e:
+            logger.error("Error while flushing Kafka producer: %s", e)
     except requests.RequestException as e:
         logger.warning("API error: %s", e)