separate noderd-kafka consumer and producer logs

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

Hide file tree

Showing 2 changed files with 10 additions and 10 deletions.
diff --git a/lib/BackbeatConsumer.js b/lib/BackbeatConsumer.js
@@ -203,11 +203,11 @@ 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', event => this._log.info('consumer.rdkafka.event', { event }));
+        this._consumer.on('event.log', log => this._log.info('consumer.rdkafka.log', { log }));
+        this._consumer.on('warning', warning => this._log.warn('consumer.rdkafka.warning', { warning }));
+        this._consumer.on('event.error', err => this._log.error('consumer.rdkafka.error', { err }));
+        this._consumer.on('event.throttle', throttle => this._log.info('consumer.rdkafka.throttle', { throttle }));
         this._consumer.on('event.stats', observeKafkaStats);
 
         this._connect();

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