log commit and rebalance events

scality · Sep 28, 2023 · 1137b8f · 1137b8f
1 parent 761cf0d
commit 1137b8f
Showing 1 changed file with 15 additions and 0 deletions.
diff --git a/lib/BackbeatConsumer.js b/lib/BackbeatConsumer.js
@@ -207,6 +207,21 @@ class BackbeatConsumer extends EventEmitter {
                 }
             });
         });
+
+        this._consumer.on('rebalance', (err, topicPartition) => {
+            this._log.debug('rebalance', {
+                err,
+                topicPartition,
+            });
+        });
+
+        this._consumer.on('offset.commit', (err, topicPartition) => {
+            this._log.debug('offset.commit', {
+                err,
+                topicPartition,
+            });
+        });
+
         return this._consumer.once('ready', () => {
             this._consumerReady = true;
             this._checkIfReady();