Merge pull request #61 from shikshalokam/kafkalogsChange

kafka logs fixes
project-sunbird · Feb 2, 2022 · 8711599 · 8711599
2 parents 1f24bb2 + 5962762
commit 8711599
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/config/kafka.js b/config/kafka.js
@@ -75,7 +75,7 @@ var _sendToKafkaConsumers = function (topic,host) {
 
       console.log("-------Kafka log starts here------------------");
       console.log("Topic Name: ", topic);
-      console.log("Message: ", JSON.stringify(message));
+      console.log(JSON.stringify(message));
       console.log("-------Kafka log ends here------------------");
 
       if (message && message.topic === SUBMISSION_TOPIC) {

diff --git a/generics/kafka/producers.js b/generics/kafka/producers.js
@@ -51,7 +51,7 @@ const pushMessageToKafka = function(payload) {
 
     console.log("-------Kafka log starts here------------------");
     console.log("Topic Name: ", payload[0].topic);
-    console.log("Message: ", JSON.stringify(payload));
+    console.log(JSON.stringify(payload));
     console.log("-------Kafka log ends here------------------");
 
     kafkaClient.kafkaProducer.send(payload, (err, data) => {