kafka bridge flushProducer timeout error not caught; fixed (#1133)

rage · Mar 13, 2023 · 8bdb5ad · 8bdb5ad
1 parent c90b6da
commit 8bdb5ad
Showing 1 changed file with 4 additions and 1 deletion.
diff --git 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()