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) } }