diff --git a/msa/js-executor/queue/kafkaTemplate.js b/msa/js-executor/queue/kafkaTemplate.js index 1d1ad75318..b9961be709 100644 --- a/msa/js-executor/queue/kafkaTemplate.js +++ b/msa/js-executor/queue/kafkaTemplate.js @@ -65,15 +65,15 @@ async function pushMessageToSendLater(message) { function sendLoopWithLinger() { if (sendLoopInstance) { clearTimeout(sendLoopInstance); - } else { - logger.debug("Starting new send loop with linger [%s]", linger) + // } else { + // logger.debug("Starting new send loop with linger [%s]", linger) } sendLoopInstance = setTimeout(sendMessagesAsBatch, linger); } async function sendMessagesAsBatch(isImmediately) { if (sendLoopInstance) { - logger.debug("sendMessagesAsBatch: Clear sendLoop scheduler. Starting new send loop with linger [%s]", linger); + // logger.debug("sendMessagesAsBatch: Clear sendLoop scheduler. Starting new send loop with linger [%s]", linger); clearTimeout(sendLoopInstance); } sendLoopInstance = null;