log kafka consume call

scality · Sep 28, 2023 · a8146e4 · a8146e4
1 parent 761cf0d
commit a8146e4
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/lib/BackbeatConsumer.js b/lib/BackbeatConsumer.js
@@ -361,6 +361,7 @@ class BackbeatConsumer extends EventEmitter {
         }
         this._nConsumePendingRequests += nNewConsumeRequests;
         return this._consumer.consume(nNewConsumeRequests, (err, entries) => {
+            this._log.debug('Kafka consumer called', { time: Date.now() });
             this._nConsumePendingRequests -= nNewConsumeRequests;
             if (!err) {
                 entries.forEach(entry => {