Debug issue where aggregate topic message is being rejected

callmekatootie · callmekatootie · commit f32a599c716a · 2021-06-29T19:33:23.000+05:30
diff --git a/src/app.js b/src/app.js
@@ -43,8 +43,8 @@ const dataHandler = (messageSet, topic, partition) => Promise.each(messageSet, a
     return
   }
 
-  logger.debug(topic, config.AGGREGATE_SUBMISSION_TOPIC, messageJSON.payload.originalTopic, config.CREATE_SUBMISSION_TOPIC)
-  logger.debug(topic === config.AGGREGATE_SUBMISSION_TOPIC, messageJSON.payload.originalTopic === config.CREATE_SUBMISSION_TOPIC)
+  console.log(topic, config.AGGREGATE_SUBMISSION_TOPIC, messageJSON.payload.originalTopic, config.CREATE_SUBMISSION_TOPIC)
+  console.log(topic === config.AGGREGATE_SUBMISSION_TOPIC, messageJSON.payload.originalTopic === config.CREATE_SUBMISSION_TOPIC)
 
   return (async () => {
     if (topic === config.REVIEW_TOPIC) {

Original file line number	Diff line number	Diff line change
`@@ -43,8 +43,8 @@ const dataHandler = (messageSet, topic, partition) => Promise.each(messageSet, a`
`43`	`43`	`return`
`44`	`44`	`}`
`45`	`45`
`46`		`- logger.debug(topic, config.AGGREGATE_SUBMISSION_TOPIC, messageJSON.payload.originalTopic, config.CREATE_SUBMISSION_TOPIC)`
`47`		`- logger.debug(topic === config.AGGREGATE_SUBMISSION_TOPIC, messageJSON.payload.originalTopic === config.CREATE_SUBMISSION_TOPIC)`
	`46`	`+ console.log(topic, config.AGGREGATE_SUBMISSION_TOPIC, messageJSON.payload.originalTopic, config.CREATE_SUBMISSION_TOPIC)`
	`47`	`+ console.log(topic === config.AGGREGATE_SUBMISSION_TOPIC, messageJSON.payload.originalTopic === config.CREATE_SUBMISSION_TOPIC)`
`48`	`48`
`49`	`49`	`return (async () => {`
`50`	`50`	`if (topic === config.REVIEW_TOPIC) {`