Update Producer.ts

egovernments · Aug 2, 2024 · 5b00d0d · 5b00d0d
1 parent fcca1ee
commit 5b00d0d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/utilities/project-factory/src/server/kafka/Producer.ts b/utilities/project-factory/src/server/kafka/Producer.ts
@@ -62,6 +62,7 @@ const sendWithRetries = (payloads: any[], retries = 3, shutdown: boolean = false
         producer.send(payloads, async (err: any) => {
             if (err) {
                 logger.error('Error sending message:', err);
+                logger.debug(`Was trying to send: ${JSON.stringify(payloads)}`);
                 if (retries > 0) {
                     logger.info(`Retrying to send message. Retries left: ${retries}`);
                     await new Promise(resolve => setTimeout(resolve, 2000)); // wait before retrying