From 5962762b8f0be8e92a04ac5831a6d66b65b4d9a5 Mon Sep 17 00:00:00 2001 From: rakeshSgr Date: Wed, 2 Feb 2022 19:05:23 +0530 Subject: [PATCH] kafka logs fixes --- config/kafka.js | 2 +- generics/kafka/producers.js | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/config/kafka.js b/config/kafka.js index b2858422..16a42e28 100644 --- 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 index 066bc8cf..7574cf2d 100644 --- 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) => {