[DEBUG] add logs

scality · Oct 10, 2024 · d1b659e · d1b659e
1 parent 728b7a7
commit d1b659e
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/lib/BackbeatConsumer.js b/lib/BackbeatConsumer.js
@@ -998,11 +998,13 @@ class BackbeatConsumer extends EventEmitter {
      * @return {undefined}
      */
     close(cb) {
+        this._log.debug('closing consumer', { topic: this._topic, groupId: this._groupId });
         if (this._publishOffsetsCronTimer) {
             clearInterval(this._publishOffsetsCronTimer);
             this._publishOffsetsCronTimer = null;
         }
         if (this._publishOffsetsCronActive) {
+            this._log.debug('publish offset cron still active', { topic: this._topic, groupId: this._groupId });
             return setTimeout(() => this.close(cb), 1000);
         }
         this._circuitBreaker.stop();

diff --git a/lib/queuePopulator/QueuePopulator.js b/lib/queuePopulator/QueuePopulator.js
@@ -296,6 +296,12 @@ class QueuePopulator {
                     method: 'QueuePopulator.close',
                 });
                 return next();
+            },
+            next => {
+                this.log.debug('closed everything', {
+                    method: 'QueuePopulator.close',
+                });
+                return next();
             }
         ], cb);
     }