Add updateMetadata configuration

quintoandar · May 22, 2018 · 2cc534f · 2cc534f
1 parent b4e58ee
commit 2cc534f
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "quintoandar-kafka",
-  "version": "0.0.8",
+  "version": "0.0.9",
   "description": "Default Kafka NodeJS lib for QuintoAndar",
   "main": "src/main.js",
   "dependencies": {

diff --git a/src/node-kafka-consumer.js b/src/node-kafka-consumer.js
@@ -15,6 +15,7 @@ class KafkaConsumer {
     _.defaults(this.configs, { fromOffset: 'latest' });
     _.defaults(this.configs, { outOfRangeOffset: 'latest' });
     _.defaults(this.configs, { fetchMaxBytes: 1024 * 1024 });
+    _.defaults(this.configs, { updateMetadata: 90 * 1000 });
   }
 
   validateConfigs() {
@@ -44,7 +45,7 @@ class KafkaConsumer {
         this.consumer.commit(msg, true);
       });
     });
-    setInterval(this.refreshMetadata.bind(this), this.sessionTimeout + 30000);
+    setInterval(this.refreshMetadata.bind(this), this.updateMetadata);
     logger.info('ConsumerGroupStream started');
   }
 

diff --git a/tests/node-kafka-consumer.test.js b/tests/node-kafka-consumer.test.js
@@ -68,7 +68,8 @@ describe('Kafka Consumer', () => {
     asyncPush: false,
     fromOffset: 'latest',
     outOfRangeOffset: 'latest',
-    fetchMaxBytes: 1024 * 1024
+    fetchMaxBytes: 1024 * 1024,
+    updateMetadata: 90000
   };
 
   const topics = ['Test'];