From 437b166e1c65c0b0da2b0d62df05de82615c121e Mon Sep 17 00:00:00 2001 From: rakeshSgr Date: Fri, 4 Feb 2022 16:17:31 +0530 Subject: [PATCH 1/2] log updated --- config/kafkaConfig.js | 6 +++--- generics/helpers/kafkaCommunications.js | 4 ++-- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/config/kafkaConfig.js b/config/kafkaConfig.js index 8da6a337..2339f24f 100644 --- a/config/kafkaConfig.js +++ b/config/kafkaConfig.js @@ -36,12 +36,12 @@ var connect = function() { consumer.on('message', async function (message) { - console.log("-------Kafka log starts here------------------"); + console.log("-------Kafka consumner log starts here------------------"); console.log("Topic Name: ", process.env.SUBMISSION_RATING_QUEUE_TOPIC); console.log(JSON.stringify(message)); - console.log("-------Kafka log ends here------------------"); + console.log("-------Kafka consumner log ends here------------------"); - submissionRatingQueueConsumer.messageReceived(message) + submissionRatingQueueConsumer.messageReceived(message) }); consumer.on('error', async function (error) { diff --git a/generics/helpers/kafkaCommunications.js b/generics/helpers/kafkaCommunications.js index 1b1fac4a..cc62ceea 100644 --- a/generics/helpers/kafkaCommunications.js +++ b/generics/helpers/kafkaCommunications.js @@ -170,10 +170,10 @@ const pushMessageToKafka = function(payload) { throw reject("Kafka configuration is not done") } - console.log("-------Kafka log starts here------------------"); + console.log("-------Kafka producer log starts here------------------"); console.log("Topic Name: ", payload[0].topic); console.log(JSON.stringify(payload)); - console.log("-------Kafka log ends here------------------"); + console.log("-------Kafka producer log ends here------------------"); kafkaClient.kafkaProducer.send(payload, (err, data) => { if (err) { From 4a8bdfb3def0a2e065dc915d4130a25a6a7fd600 Mon Sep 17 00:00:00 2001 From: rakeshSgr Date: Fri, 4 Feb 2022 16:21:24 +0530 Subject: [PATCH 2/2] update log --- config/kafkaConfig.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/config/kafkaConfig.js b/config/kafkaConfig.js index 2339f24f..f657dab6 100644 --- a/config/kafkaConfig.js +++ b/config/kafkaConfig.js @@ -36,10 +36,10 @@ var connect = function() { consumer.on('message', async function (message) { - console.log("-------Kafka consumner log starts here------------------"); + console.log("-------Kafka consumer log starts here------------------"); console.log("Topic Name: ", process.env.SUBMISSION_RATING_QUEUE_TOPIC); console.log(JSON.stringify(message)); - console.log("-------Kafka consumner log ends here------------------"); + console.log("-------Kafka consumer log ends here------------------"); submissionRatingQueueConsumer.messageReceived(message) });