File tree 2 files changed +7
-4
lines changed 2 files changed +7
-4
lines changed Original file line number Diff line number Diff line change @@ -144,6 +144,7 @@ function start () {
144
144
145
145
schedule . scheduleJob ( config . EMAIL_RETRY_SCHEDULE , async function ( ) {
146
146
try {
147
+ logger . info ( "Retrying failed emails" )
147
148
await retryEmail ( handlers )
148
149
} catch ( err ) {
149
150
console . log ( 'Error in retrying email' , err )
Original file line number Diff line number Diff line change @@ -28,7 +28,9 @@ async function configureKafkaConsumer (handlers) {
28
28
const kafka = new Kafka ( options )
29
29
const consumer = kafka . consumer ( { groupId : config . KAFKA_GROUP_ID } )
30
30
31
+ logger . info ( "Connecting to Kafka..." )
31
32
await consumer . connect ( )
33
+ logger . info ( `Subscribing to topics: ${ _ . keys ( handlers ) } ` )
32
34
await consumer . subscribe ( { topics : _ . keys ( handlers ) } )
33
35
dataHandler ( consumer , handlers ) . catch ( ( err ) => {
34
36
console . log ( 'error' , 'Kafka consumer error' , err )
@@ -93,7 +95,7 @@ async function dataHandler (consumer, handlers) {
93
95
} catch ( e ) {
94
96
await logger . endSpanWithError ( span , e )
95
97
logger . error ( e )
96
- }
98
+ }
97
99
}
98
100
} )
99
101
} catch ( e ) {
@@ -124,7 +126,7 @@ async function dataHandler (consumer, handlers) {
124
126
process . kill ( process . pid , type )
125
127
}
126
128
} )
127
- } )
129
+ } )
128
130
}
129
131
130
132
/**
@@ -160,7 +162,7 @@ async function retryEmail (handlers) {
160
162
} else {
161
163
await logger . endSpan ( span )
162
164
return models
163
- }
165
+ }
164
166
}
165
167
166
168
async function initServer ( handlers ) {
@@ -179,4 +181,4 @@ module.exports = {
179
181
retryEmail
180
182
}
181
183
182
- logger . buildService ( module . exports )
184
+ logger . buildService ( module . exports )
You can’t perform that action at this time.
0 commit comments