fix: add clean exit with code 1 for Kafka producer error

Fixes issue #9
csye7125-fall2023-group05 · Nov 20, 2023 · 25b4cbf · 25b4cbf
1 parent 4e18743
commit 25b4cbf
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 1 deletion.
diff --git 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
@@ -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)
   }
 }