File tree Expand file tree Collapse file tree 2 files changed +7
-3
lines changed
Expand file tree Collapse file tree 2 files changed +7
-3
lines changed Original file line number Diff line number Diff line change @@ -167,13 +167,17 @@ class GarbageCollector extends EventEmitter {
167167 }
168168
169169 /**
170- * Close the lifecycle consumer
170+ * Close the garbage collector consumer
171171 * @param {function } cb - callback function
172172 * @return {undefined }
173173 */
174174 close ( cb ) {
175175 this . _logger . debug ( 'closing garbage collector consumer' ) ;
176- this . _consumer . close ( cb ) ;
176+ if ( this . _consumer ) {
177+ this . _consumer . close ( cb ) ;
178+ } else {
179+ cb ( ) ;
180+ }
177181 }
178182
179183 processKafkaEntry ( kafkaEntry , done ) {
Original file line number Diff line number Diff line change @@ -100,7 +100,7 @@ initAndStart();
100100
101101process . on ( 'SIGTERM' , ( ) => {
102102 logger . info ( 'received SIGTERM, exiting' ) ;
103- garbageCollector . stop ( ( ) => {
103+ garbageCollector . close ( ( ) => {
104104 process . exit ( 0 ) ;
105105 } ) ;
106106} ) ;
You can’t perform that action at this time.
0 commit comments