Skip to content

Commit d7845f4

Browse files
Update consumer.js
1 parent ef72f26 commit d7845f4

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/consumer.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ async function dataHandler (messageSet, topic, partition) {
8585
try {
8686
const payload = JSON.parse(m.message.value)
8787
logger.debug('Received payload from kafka:')
88-
logger.debug(payload)
88+
// logger.debug(payload)
8989
await updateInformix(payload)
9090
await consumer.commitOffset({ topic, partition, offset: m.offset }) // Commit offset only on success
9191
} catch (err) {

0 commit comments

Comments
 (0)