quintoandar-kafka - npm Package Compare versions

Comparing version 0.0.8 to 0.0.9

package.json

 {
   "name": "quintoandar-kafka",
-  "version": "0.0.8",
+  "version": "0.0.9",
   "description": "Default Kafka NodeJS lib for QuintoAndar",
@@ -5,0 +5,0 @@ "main": "src/main.js",

src/node-kafka-consumer.js

@@ -18,2 +18,3 @@ const kafka = require('kafka-node');
     _.defaults(this.configs, { fetchMaxBytes: 1024 * 1024 });
+    _.defaults(this.configs, { updateMetadata: 90 * 1000 });
   }
@@ -48,3 +49,3 @@
     });
-    setInterval(this.refreshMetadata.bind(this), this.sessionTimeout + 30000);
+    setInterval(this.refreshMetadata.bind(this), this.updateMetadata);
     logger.info('ConsumerGroupStream started');
@@ -51,0 +52,0 @@ }

tests/node-kafka-consumer.test.js

@@ -71,3 +71,4 @@ jest.mock('kafka-node');
     outOfRangeOffset: 'latest',
-    fetchMaxBytes: 1024 * 1024
+    fetchMaxBytes: 1024 * 1024,
+    updateMetadata: 90000
   };
@@ -74,0 +75,0 @@

No alert changes

Improved metrics

Total package byte prevSize

16524

increased by0.49%

Lines of code

440

increased by0.46%

No dependency changes