Merge pull request #68 from shikshalokam/kafka_logs

Kafka logs

Author: aks30

config/kafkaConfig.js

@@ -38,7 +38,7 @@ var connect = function() {
 
           console.log("-------Kafka log starts here------------------");
           console.log("Topic Name: ", process.env.SUBMISSION_RATING_QUEUE_TOPIC);
-          console.log("Message: ", JSON.stringify(message));
+          console.log(JSON.stringify(message));
           console.log("-------Kafka log ends here------------------");
 
           submissionRatingQueueConsumer.messageReceived(message)

generics/helpers/kafkaCommunications.js

@@ -18,8 +18,6 @@ const pushObservationSubmissionToKafka = function (message) {
             messages: JSON.stringify(message)
           }])
 
-          console.log("data is",kafkaPushStatus)
-
           return resolve(kafkaPushStatus)
 
       } catch (error) {
@@ -174,7 +172,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) => {

module/observationSubmissions/helper.js

@@ -125,7 +125,7 @@ module.exports = class ObservationSubmissionsHelper {
                 }
 
 
-                console.log("--- logs starts here -----");
+
                 const kafkaMessage = await kafkaClient.pushObservationSubmissionToKafka(observationSubmissionsDocument);
 
                 if(kafkaMessage.status != "success") {
@@ -138,8 +138,6 @@ module.exports = class ObservationSubmissionsHelper {
                     console.log(errorObject);
                 }
 
-                console.log("--logs ends here---")
-
                 return resolve(kafkaMessage);
 
             } catch (error) {