Merge pull request #60 from shikshalokam/kafkalogsChange

kafka logs added
project-sunbird · Feb 2, 2022 · 1f24bb2 · 1f24bb2
2 parents e5a1f0f + a5710e4
commit 1f24bb2
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/config/kafka.js b/config/kafka.js
@@ -73,6 +73,10 @@ var _sendToKafkaConsumers = function (topic,host) {
 
     consumer.on('message', async function (message) {
 
+      console.log("-------Kafka log starts here------------------");
+      console.log("Topic Name: ", topic);
+      console.log("Message: ", JSON.stringify(message));
+      console.log("-------Kafka log ends here------------------");
 
       if (message && message.topic === SUBMISSION_TOPIC) {
         submissionsConsumer.messageReceived(message);

diff --git a/generics/kafka/producers.js b/generics/kafka/producers.js
@@ -49,6 +49,11 @@ const pushMessageToKafka = function(payload) {
       throw reject("Kafka configuration is not done");
     }
 
+    console.log("-------Kafka log starts here------------------");
+    console.log("Topic Name: ", payload[0].topic);
+    console.log("Message: ", JSON.stringify(payload));
+    console.log("-------Kafka log ends here------------------");
+
     kafkaClient.kafkaProducer.send(payload, (err, data) => {
       if (err) {
         return reject("Kafka push to topic "+ payload[0].topic +" failed.");