Debug issue where aggregate topic message is being rejected

callmekatootie · callmekatootie · commit 70f05f278e04 · 2021-06-29T19:10:31.000+05:30
diff --git a/src/app.js b/src/app.js
@@ -43,6 +43,9 @@ 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)
+
   return (async () => {
     if (topic === config.REVIEW_TOPIC) {
       await ReviewProcessorService.processReview(messageJSON)

Original file line number	Diff line number	Diff line change
`@@ -43,6 +43,9 @@ 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)`
	`48`	`+`
`46`	`49`	`return (async () => {`
`47`	`50`	`if (topic === config.REVIEW_TOPIC) {`
`48`	`51`	`await ReviewProcessorService.processReview(messageJSON)`