Renamed the producer fucntion and added a flag to enable and disable …

…Metrics
Sunbird-RC · Sep 1, 2023 · 44927db · 44927db
1 parent 7894b02
commit 44927db
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 6 deletions.
diff --git a/backend/donor-service/services/kafka.producer.js b/backend/donor-service/services/kafka.producer.js
@@ -2,7 +2,7 @@ const config = require('../configs/config');
 const { Kafka, Partitioners } = require('kafkajs');
 
 // Connect and send the event
-async function produceEventToKafka(topic, telemetryEvent) {
+async function emitEventToKafka(topic, telemetryEvent) {
 
 const kafka = new Kafka({
   clientId: 'dB-Migration',
@@ -26,6 +26,6 @@ const producer = kafka.producer();
 }
 
 module.exports = {
-  produceEventToKafka
+  emitEventToKafka
 }
 
diff --git a/backend/donor-service/utils/scriptForDataMigration.js b/backend/donor-service/utils/scriptForDataMigration.js
@@ -2,7 +2,6 @@ const { default: axios } = require('axios');
 const config = require('../configs/config');
 const op = require('object-path');
 const kafkaClient =require('../services/kafka.producer');
-const { Kafka, Partitioners } = require('kafkajs');
 
 
 const topicName = `${config.METRICS_TOPIC}`; 
@@ -20,7 +19,7 @@ async function migrateDataToCH (entityName, entityId, accessToken) {
     if (getTheDataFromRegistry.data && getTheDataFromRegistry.data != '') {
       let transformedData = transformTheData(getTheDataFromRegistry.data, entityName);
       let telemertryObject = getTelemtryObject( entityName , entityId,transformedData);
-      await kafkaClient.produceEventToKafka(topicName, telemertryObject) 
+      await kafkaClient.emitEventToKafka(topicName, telemertryObject) 
       console.log("Migration was successfull!");
     }
   } catch (error) {

diff --git a/docker-compose.yml b/docker-compose.yml
@@ -77,7 +77,7 @@ services:
       - external_entities=nha-admin
       - invite_required_validation_enabled=false
       - invite_signature_enabled=false
-      - event_enabled=true
+      - event_enabled=${ENABLE_METRICS_SERVICE-false}
       - event_topic=${METRICS_TOPIC-events}
       - event_providerName=dev.sunbirdrc.registry.service.impl.KafkaEventService
     ports:
@@ -374,5 +374,5 @@ services:
       ESIGN_VALIDATION_KAFKA_TOPIC: ${ESIGN_VALIDATION_KAFKA_TOPIC}
       ESIGN_VALIDATION_KAFKA_TOPIC_GROUP: ${ESIGN_VALIDATION_KAFKA_TOPIC_GROUP}
       METRICS_URL: ${METRICS_URL}
-      KAFKA_BROKER: ${KAFKA_BROKER}
+      KAFKA_BROKER_FOR_METRICS_SERVICE: ${KAFKA_BROKER_FOR_METRICS_SERVICE}
       METRICS_TOPIC: ${METRICS_TOPIC}