[DEBUG] add logs

scality · Mar 3, 2025 · e49f23b · e49f23b
1 parent 0a80325
commit e49f23b
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 2 deletions.
diff --git a/lib/BackbeatConsumer.js b/lib/BackbeatConsumer.js
@@ -1007,6 +1007,10 @@ 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;
@@ -1025,24 +1029,42 @@ class BackbeatConsumer extends EventEmitter {
                         // disconnecting, the rebalance callback will handle
                         // waiting for current jobs to complete as well as commit
                         // the latest offsets
+                        this._log.debug('waiting for unassign', {
+                            topic: this._topic,
+                            groupId: this._groupId,
+                        });
                         this.once('unassign', () => next());
                         return;
                     }
                 }
+                this._log.debug('no partitions assigned, disconnecting consumer', {
+                    topic: this._topic,
+                    groupId: this._groupId,
+                });
                 process.nextTick(next);
             },
             next => {
                 if (this._zookeeper) {
                     this._zookeeper.close();
                 }
                 if (this._consumer?.isConnected()) {
+                    this._log.debug('disconnecting consumer', {
+                        topic: this._topic,
+                        groupId: this._groupId,
+                    });
                     this._consumer.disconnect();
                     this._consumer.once('disconnected', () => next());
                 } else {
                     process.nextTick(next);
                 }
             },
-        ], () => cb());
+        ], () => {
+            this._log.debug('backbeat consumer disconnected', {
+                topic: this._topic,
+                groupId: this._groupId,
+            });
+            cb();
+        });
     }
 }
 

diff --git a/tests/functional/queuePopulator/config/s3c-config.json b/tests/functional/queuePopulator/config/s3c-config.json
@@ -148,7 +148,7 @@
     }
   },
   "log": {
-    "logLevel": "info",
+    "logLevel": "debug",
     "dumpLevel": "error"
   },
   "server": {