delay implementation in repost

Author: Gunasekar-K

.circleci/config.yml

@@ -50,9 +50,9 @@ builddeploy_steps: &builddeploy_steps
             # # consumer deployment
             # rm -rf buildenvvar
             # ./unsetenv.sh
-            # ./buildenv.sh -e $DEPLOY_ENV -b ${LOGICAL_ENV}-${APPNAME}-consumer-deployvar
-            # source buildenvvar            
-            # ./master_deploy.sh -d ECS -e $DEPLOY_ENV -t latest -s ${LOGICAL_ENV}-global-appvar,${LOGICAL_ENV}-${APPNAME}-appvar -i ${APPNAME}
+            ./buildenv.sh -e $DEPLOY_ENV -b ${LOGICAL_ENV}-${APPNAME}-consumer-deployvar
+            source buildenvvar            
+            ./master_deploy.sh -d ECS -e $DEPLOY_ENV -t latest -s ${LOGICAL_ENV}-global-appvar,${LOGICAL_ENV}-${APPNAME}-appvar -i ${APPNAME}
             # # without kafka dynamodb
             # rm -rf buildenvvar
             # ./unsetenv.sh
@@ -62,9 +62,9 @@ builddeploy_steps: &builddeploy_steps
             # # reconciler deployment
             # rm -rf buildenvvar
             # ./unsetenv.sh            
-             ./buildenv.sh -e $DEPLOY_ENV -b ${LOGICAL_ENV}-${APPNAME}-reconciler-deployvar
-             source buildenvvar
-             ./master_deploy.sh -d ECS -e $DEPLOY_ENV -t latest -s ${LOGICAL_ENV}-global-appvar,${LOGICAL_ENV}-${APPNAME}-appvar -i ${APPNAME}
+            #  ./buildenv.sh -e $DEPLOY_ENV -b ${LOGICAL_ENV}-${APPNAME}-reconciler-deployvar
+            #  source buildenvvar
+            #  ./master_deploy.sh -d ECS -e $DEPLOY_ENV -t latest -s ${LOGICAL_ENV}-global-appvar,${LOGICAL_ENV}-${APPNAME}-appvar -i ${APPNAME}
 
 
 jobs:

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