From ee044a0be811a53842c69f64c27d9995d84b7040 Mon Sep 17 00:00:00 2001
From: harsh-sharma-juspay
 <125131007+harsh-sharma-juspay@users.noreply.github.com>
Date: Tue, 9 Jan 2024 15:03:47 +0530
Subject: [PATCH] fix(outgoingwebhookevents): Throw an error when outgoing
 webhook events env var not found (#3291)

---
 crates/router/src/services/kafka.rs | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/crates/router/src/services/kafka.rs b/crates/router/src/services/kafka.rs
index 2b29a61b4a..2bcfcfe974 100644
--- a/crates/router/src/services/kafka.rs
+++ b/crates/router/src/services/kafka.rs
@@ -126,6 +126,15 @@ impl KafkaSettings {
             ))
         })?;
 
+        common_utils::fp_utils::when(
+            self.outgoing_webhook_logs_topic.is_default_or_empty(),
+            || {
+                Err(ApplicationError::InvalidConfigurationValueError(
+                    "Kafka Outgoing Webhook Logs topic must not be empty".into(),
+                ))
+            },
+        )?;
+
         Ok(())
     }
 }