@@ -22,8 +22,9 @@ module.exports = {
22
22
database : process . env . PG_DATABASE || 'postgres' , // database must exist before running the tool
23
23
password : process . env . PG_PASSWORD || 'password' ,
24
24
port : parseInt ( process . env . PG_PORT , 10 ) || 5432 ,
25
- triggerFunctions : process . env . TRIGGER_FUNCTIONS || [ 'prod_db_notifications' ] , // List of trigger functions to listen to
26
- triggerTopics : process . env . TRIGGER_TOPICS || [ 'prod.db.postgres.sync' ] , // Names of the topic in the trigger payload
25
+
26
+ triggerFunctions : process . env . TRIGGER_FUNCTIONS || 'dev_db_notifications' , // List of trigger functions to listen to
27
+ triggerTopics : process . env . TRIGGER_TOPICS || [ 'dev.db.postgres.sync' ] , // Names of the topic in the trigger payload
27
28
triggerOriginators : process . env . TRIGGER_ORIGINATORS || [ 'tc-postgres-delta-processor' ] // Names of the originator in the trigger payload
28
29
} ,
29
30
KAFKA : { // Kafka connection options
@@ -34,32 +35,36 @@ module.exports = {
34
35
} ,
35
36
topic : process . env . KAFKA_TOPIC || 'db.topic.sync' , // Kafka topic to push and receive messages
36
37
partition : process . env . partition || [ 0 ] , // Kafka partitions to use
37
- maxRetry : process . env . MAX_RETRY || 3 ,
38
+ maxRetry : process . env . MAX_RETRY || 10 ,
38
39
errorTopic : process . env . ERROR_TOPIC || 'db.scorecardtable.error' ,
39
- recipients :
[ '[email protected] ' ] // Kafka partitions to use
40
+ recipients :
[ '[email protected] ' ] , // Kafka partitions to use,
41
+ KAFKA_URL : process . env . KAFKA_URL ,
42
+ KAFKA_GROUP_ID : process . env . KAFKA_GROUP_ID || 'dev-postgres-ifx-consumer' ,
43
+ KAFKA_CLIENT_CERT : process . env . KAFKA_CLIENT_CERT ? process . env . KAFKA_CLIENT_CERT . replace ( '\\n' , '\n' ) : null ,
44
+ KAFKA_CLIENT_CERT_KEY : process . env . KAFKA_CLIENT_CERT_KEY ? process . env . KAFKA_CLIENT_CERT_KEY . replace ( '\\n' , '\n' ) : null ,
40
45
} ,
41
46
SLACK : {
42
47
URL : process . env . SLACKURL || 'us-east-1' ,
43
48
SLACKCHANNEL : process . env . SLACKCHANNEL || 'ifxpg-migrator' ,
44
- SLACKNOTIFY : process . env . SLACKNOTIFY || 'false'
49
+ SLACKNOTIFY : process . env . SLACKNOTIFY || 'false'
45
50
} ,
46
- RECONSILER :{
51
+ RECONSILER : {
47
52
RECONSILER_START : process . env . RECONSILER_START || 5 ,
48
53
RECONSILER_END : process . env . RECONSILER_END || 1 ,
49
54
RECONSILER_DURATION_TYPE : process . env . RECONSILER_DURATION_TYPE || 'm'
50
55
} ,
51
56
DYNAMODB :
52
- {
53
- DYNAMODB_TABLE : process . env . DYNAMODB_TABLE || 'dev_pg_ifx_payload_sync' ,
54
- DD_ElapsedTime : process . env . DD_ElapsedTime || 600000
55
- } ,
57
+ {
58
+ DYNAMODB_TABLE : process . env . DYNAMODB_TABLE || 'dev_pg_ifx_payload_sync' ,
59
+ DD_ElapsedTime : process . env . DD_ElapsedTime || 600000
60
+ } ,
56
61
57
- AUTH0_URL : process . env . AUTH0_URL ,
58
- AUTH0_AUDIENCE : process . env . AUTH0_AUDIENCE ,
59
- TOKEN_CACHE_TIME : process . env . TOKEN_CACHE_TIME ,
60
- AUTH0_CLIENT_ID : process . env . AUTH0_CLIENT_ID ,
61
- AUTH0_CLIENT_SECRET : process . env . AUTH0_CLIENT_SECRET ,
62
- BUSAPI_URL : process . env . BUSAPI_URL ,
63
- KAFKA_ERROR_TOPIC : process . env . KAFKA_ERROR_TOPIC ,
64
- AUTH0_PROXY_SERVER_URL : process . env . AUTH0_PROXY_SERVER_URL
62
+ AUTH0_URL : process . env . AUTH0_URL ,
63
+ AUTH0_AUDIENCE : process . env . AUTH0_AUDIENCE ,
64
+ TOKEN_CACHE_TIME : process . env . TOKEN_CACHE_TIME ,
65
+ AUTH0_CLIENT_ID : process . env . AUTH0_CLIENT_ID ,
66
+ AUTH0_CLIENT_SECRET : process . env . AUTH0_CLIENT_SECRET ,
67
+ BUSAPI_URL : process . env . BUSAPI_URL ,
68
+ KAFKA_ERROR_TOPIC : process . env . KAFKA_ERROR_TOPIC ,
69
+ AUTH0_PROXY_SERVER_URL : process . env . AUTH0_PROXY_SERVER_URL
65
70
}
0 commit comments