separate noderd-kafka consumer and producer logs

scality · Oct 6, 2023 · b322ad9 · b322ad9
1 parent ecc6c67
commit b322ad9
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 12 deletions.
diff --git a/lib/BackbeatConsumer.js b/lib/BackbeatConsumer.js
@@ -203,12 +203,12 @@ class BackbeatConsumer extends EventEmitter {
         }
         this._consumer = new kafka.KafkaConsumer(consumerParams, topicParams);
 
-        this._consumer.on('event', event => this._log.info('rdkafka.event', { event }));
-        this._consumer.on('event.log', log => this._log.info('rdkafka.log', { log }));
-        this._consumer.on('warning', warning => this._log.warn('rdkafka.warning', { warning }));
-        this._consumer.on('event.error', err => this._log.error('rdkafka.error', { err }));
-        this._consumer.on('event.throttle', throttle => this._log.info('rdkafka.throttle', { throttle }));
-        this._consumer.on('event.stats', observeKafkaStats);
+        this._consumer.on('event consumer', event => this._log.info('rdkafka.event', { event }));
+        this._consumer.on('event.log consumer', log => this._log.info('rdkafka.log', { log }));
+        this._consumer.on('warning consumer', warning => this._log.warn('rdkafka.warning', { warning }));
+        this._consumer.on('event.error consumer', err => this._log.error('rdkafka.error', { err }));
+        this._consumer.on('event.throttle consumer', throttle => this._log.info('rdkafka.throttle', { throttle }));
+        this._consumer.on('event.stats consumer', observeKafkaStats);
 
         this._connect();
     }

diff --git a/lib/BackbeatProducer.js b/lib/BackbeatProducer.js
@@ -33,12 +33,12 @@ class BackbeatProducer extends EventEmitter {
 
         this._producer = new Producer(this.producerConfig, this.topicConfig);
 
-        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);
+        this._producer.on('event producer', event => this._log.info('rdkafka.event', { event }));
+        this._producer.on('event.log producer', log => this._log.info('rdkafka.log', { log }));
+        this._producer.on('warning producer', warning => this._log.warn('rdkafka.warning', { warning }));
+        this._producer.on('event.error producer', err => this._log.error('rdkafka.error', { err }));
+        this._producer.on('event.throttle producer', throttle => this._log.info('rdkafka.throttle', { throttle }));
+        this._producer.on('event.stats producer', observeKafkaStats);
 
         this.connect();
         this.setListeners();