diff --git a/backend/bin/kafkaBridge.ts b/backend/bin/kafkaBridge.ts
index 8c6fce45d..51c949585 100644
--- a/backend/bin/kafkaBridge.ts
+++ b/backend/bin/kafkaBridge.ts
@@ -83,7 +83,10 @@ app.post("/kafka-bridge/api/v0/event", async (req, res) => {
 
   try {
     producer.produce(topic, null, Buffer.from(JSON.stringify(payload)))
-    flushProducer(1000)
+    flushProducer(1000).catch((err) => {
+      logger.warn(new KafkaError("Flushing the producer failed", err))
+      return res.status(500).json({ error: err.toString() }).send()
+    })
   } catch (e: any) {
     logger.error(new KafkaError("Producing to kafka failed", e))
     return res.status(500).json({ error: e.toString() }).send()