Fix BackbeatProducer event.error handlers set twice.

scality · Sep 3, 2024 · cced960 · cced960
1 parent e7d6e10
commit cced960
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/lib/BackbeatProducer.js b/lib/BackbeatProducer.js
@@ -36,7 +36,6 @@ class BackbeatProducer extends EventEmitter {
         this._producer.on('event', event => this._log.info('rdkafka.event', { event }));
         this._producer.on('event.log', log => this._log.info('rdkafka.log', { log }));
         this._producer.on('warning', warning => this._log.warn('rdkafka.warning', { warning }));
-        this._producer.on('event.error', err => this._log.error('rdkafka.error', { err }));
         this._producer.on('event.throttle', throttle => this._log.info('rdkafka.throttle', { throttle }));
         this._producer.on('event.stats', observeKafkaStats);