fix: udpate env vars from CM to include name, retries

config/app.config.js

@@ -1,13 +1,16 @@
 import 'dotenv/config'
 
-const { BROKER_0, BROKER_1, BROKER_2, CLIENT_ID, TOPIC, URL } = process.env
+const { BROKER_0, BROKER_1, BROKER_2, CLIENT_ID, TOPIC, URL, NAME, RETRIES } =
+  process.env
 const producerConfig = {
   BROKER_0,
   BROKER_1,
   BROKER_2,
   CLIENT_ID,
   TOPIC,
   URL,
+  NAME,
+  RETRIES,
 }
 
 export default producerConfig

index.js

@@ -2,7 +2,8 @@ import { Kafka } from 'kafkajs'
 import logger from './config/logger.config.js'
 import producerConfig from './config/app.config.js'
 
-const { BROKER_0, BROKER_1, BROKER_2, CLIENT_ID, TOPIC, URL } = producerConfig
+const { BROKER_0, BROKER_1, BROKER_2, CLIENT_ID, TOPIC, URL, NAME, RETRIES } =
+  producerConfig
 const topic = TOPIC
 const brokers = [BROKER_0, BROKER_1, BROKER_2]
 
@@ -19,15 +20,15 @@ const init = async () => {
     const response = await fetch(URL)
     const status = await response.status
     const data = {
-      name: 'google',
+      name: NAME,
       uri: URL,
-      is_paused: true,
-      num_retries: 5,
-      uptime_sla: 100,
-      response_time_sla: 100,
-      use_ssl: true,
+      num_retries: RETRIES,
+      // is_paused: true,
+      // uptime_sla: 100,
+      // response_time_sla: 100,
+      // use_ssl: true,
       response_status_code: status,
-      check_interval_in_seconds: 86400,
+      // check_interval_in_seconds: 86400,
     }
     const result = await producer.send({
       topic,