From 25b4cbf45f5f2f96a3aa825a48602472b61667e6 Mon Sep 17 00:00:00 2001
From: Siddharth Rawat <rawat.sid@northeastern.edu>
Date: Sun, 19 Nov 2023 20:08:09 -0500
Subject: [PATCH] fix: add clean exit with code 1 for Kafka producer error

Fixes issue #9
---
 .env.example | 9 +++++++++
 index.js     | 3 ++-
 2 files changed, 11 insertions(+), 1 deletion(-)

diff --git a/.env.example b/.env.example
index 23df2c2..353f8fb 100644
--- a/.env.example
+++ b/.env.example
@@ -3,3 +3,12 @@ BROKER_1=
 BROKER_2=
 CLIENT_ID=
 TOPIC=
+NAME=
+URL=
+IS_PAUSED=
+NUM_RETRIES=
+UPTIME_SLA=
+RESPONSE_TIME_SLA=
+USE_SSL=
+RESPONSE_STATUS_CODE=
+CHECK_INTERVAL_IN_SECONDS=
diff --git a/index.js b/index.js
index 369b3e2..630e290 100644
--- a/index.js
+++ b/index.js
@@ -41,9 +41,10 @@ const init = async () => {
       ],
     })
     logger.info(`Message sent`, { msg: data, res: result })
-    await producer.disconnect()
+    await producer.disconnect() // performs clean exit
   } catch (error) {
     logger.error(`Kafka producer error`, { error })
+    process.exit(1)
   }
 }