diff --git a/config/kafkaConfig.js b/config/kafkaConfig.js
index 8da6a337..f657dab6 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 consumer 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 consumer 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) {