kafka changes

project-sunbird · Feb 4, 2022 · afeae08 · afeae08
1 parent 79f54a3
commit afeae08
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/module/observationSubmissions/helper.js b/module/observationSubmissions/helper.js
@@ -130,7 +130,7 @@ module.exports = class ObservationSubmissionsHelper {
 
                 console.log("BEFORE CALLING pushObservationSubmissionToKafka method ");
                 const kafkaMessage = await kafkaClient.pushObservationSubmissionToKafka(observationSubmissionsDocument);
-                console.log("AFTER CALLING pushObservationSubmissionToKafka method ",kafkaMessage);
+                console.log("AFTER CALLING pushObservationSubmissionToKafka method ",JSON.stringify(kafkaMessage));
 
                 if(kafkaMessage.status != "success") {
                     let errorObject = {
@@ -146,7 +146,7 @@ module.exports = class ObservationSubmissionsHelper {
 
             } catch (error) {
 
-                console.log("pushObservationSubmissionForReporting() catch block",error);
+                console.log("pushObservationSubmissionForReporting() catch block",JSON.stringify(error));
                 return reject({
                     success: false,
                     message: error.message,
@@ -355,7 +355,7 @@ module.exports = class ObservationSubmissionsHelper {
 
 
             } catch (error) {
-                console.log("rateSubmissionById() catch block",error);
+                console.log("rateSubmissionById() catch block",JSON.stringify(error));
 
                 emailClient.pushMailToEmailService(emailRecipients,messageConstants.apiResponses.OBSERVATION_AUTO_RATING_FAILED+" - "+submissionId,error.message);
                 return reject(error);