Merge pull request #9 from topcoder-platform/dev

delay on repost

Author: Gunasekar-K

config/default.js

@@ -10,6 +10,7 @@ module.exports = {
   },
   RETRY_COUNTER: parseInt(process.env.RETRY_COUNTER || 3, 10),
   KAFKA_REPOST_COUNT: parseInt(process.env.KAFKA_REPOST_COUNT || 5, 10),
+  KAFKA_REPOST_DELAY: parseInt(process.env.KAFKA_REPOST_DELAY || 2000, 10),
   KAFKA_URL: process.env.KAFKA_URL,
   KAFKA_GROUP_ID: process.env.KAFKA_GROUP_ID || 'ifx-pg-consumer',
   KAFKA_CLIENT_CERT: process.env.KAFKA_CLIENT_CERT ? process.env.KAFKA_CLIENT_CERT.replace('\\n', '\n') : null,

src/api/consumer_retry.js

@@ -11,6 +11,7 @@ async function consumerretry(producer, payload) {
   } catch (error) {
     logger.logFullError(error)
   }
+  await sleep(config.KAFKA_REPOST_DELAY)
   kafka_error = await pushToKafka(producer, config.topic.NAME, payload)
   //add auditlog
   if (!kafka_error) {
@@ -38,5 +39,7 @@ async function consumerretry(producer, payload) {
 
   }
 }
-
+async function sleep(ms) {
+  return new Promise(resolve => setTimeout(resolve, ms));
+}
 module.exports = consumerretry