Update consumer.js

nkumar-topcoder · web-flow · commit 16a64384129f · 2020-06-30T14:49:32.000+05:30
diff --git a/src/consumer.js b/src/consumer.js
@@ -118,7 +118,7 @@ async function retrypushtokakfa(message, topic, m, partition) {
     const errmsg1 = `error-sync: postgres-ifx-processor: consumer : Error-republishing: "${err.message}"`
     logger.error(errmsg1)
     logger.debug(`error-sync: consumer re-publishing "${err.message}"`)
-     await callposttoslack(errmsg1)
+    await callposttoslack(errmsg1)
   } finally {
     await consumer.commitOffset({ topic, partition, offset: m.offset }) // Commit success as will re-publish
   }

Original file line number	Diff line number	Diff line change
`@@ -118,7 +118,7 @@ async function retrypushtokakfa(message, topic, m, partition) {`
`118`	`118`	const errmsg1 = `error-sync: postgres-ifx-processor: consumer : Error-republishing: "${err.message}"`
`119`	`119`	`logger.error(errmsg1)`
`120`	`120`	logger.debug(`error-sync: consumer re-publishing "${err.message}"`)
`121`		`- await callposttoslack(errmsg1)`
	`121`	`+ await callposttoslack(errmsg1)`
`122`	`122`	`} finally {`
`123`	`123`	`await consumer.commitOffset({ topic, partition, offset: m.offset }) // Commit success as will re-publish`
`124`	`124`	`}`