chore: add consumer handler debug log

maxceem · maxceem · commit 5d43357da404 · 2021-05-19T16:33:28.000+03:00
diff --git a/src/app.js b/src/app.js
@@ -153,6 +153,7 @@ async function initConsumer () {
       subscriptions: topics,
       handler: async (messageSet, topic, partition) => {
         eventEmitter.emit('start_handling_message')
+        localLogger.debug(`Consumer handler. Topic: ${topic}, partition: ${partition}, message set length: ${messageSet.length}`)
         await dataHandler(messageSet, topic, partition)
         eventEmitter.emit('end_handling_message')
       }

Original file line number	Diff line number	Diff line change
`@@ -153,6 +153,7 @@ async function initConsumer () {`
`153`	`153`	`subscriptions: topics,`
`154`	`154`	`handler: async (messageSet, topic, partition) => {`
`155`	`155`	`eventEmitter.emit('start_handling_message')`
	`156`	+ localLogger.debug(`Consumer handler. Topic: ${topic}, partition: ${partition}, message set length: ${messageSet.length}`)
`156`	`157`	`await dataHandler(messageSet, topic, partition)`
`157`	`158`	`eventEmitter.emit('end_handling_message')`
`158`	`159`	`}`