Catch assign error

Issue: BB-441
scality · Oct 5, 2023 · 6162a05 · 6162a05
1 parent 77b4db5
commit 6162a05
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/lib/BackbeatConsumer.js b/lib/BackbeatConsumer.js
@@ -183,7 +183,17 @@ class BackbeatConsumer extends EventEmitter {
             'rebalance_cb': (err, assignment) => {
                 if (err.code === kafka.CODES.ERRORS.ERR__ASSIGN_PARTITIONS) {
                     this._log.debug('rdkafka.assign', { err, assignment });
-                    this._consumer.assign(assignment);
+
+                    try {
+                        this._consumer.assign(assignment);
+                    } catch (e) {
+                        // Ignore exceptions if we are not connected
+                        if (this._consumer.isConnected()) {
+                            this._log.error('rdkafka.assign failed', { err, e, assignment });
+                        } else {
+                            this._log.debug('rdkafka.assign failed while !connected', { err, e, assignment });
+                        }
+                    }
                 } else if (err.code === kafka.CODES.ERRORS.ERR__REVOKE_PARTITIONS) {
                     this._log.debug('rdkafka.revoke', { err });