kafka-observe - npm Package Compare versions

Comparing version 2.0.1-alpha-2 to 2.0.1-alpha-3

IO/consumer.js

@@ -38,5 +38,3 @@ const Kafkajs = require("kafkajs");
 		await consumer.connect();
-		this.options.topicsToFollow.forEach(topic => {
-			await this.consumer.subscribe({ topic })
-		});
+		await Promise.all(this.options.topicsToFollow.map(topic => this.consumer.subscribe({ topic })));
 		logging.report(`Listening to kafka topics in all partions mode to the following topics: ${this.options.topicsToFollow.toString()}`);
@@ -43,0 +41,0 @@ await consumer.run({

IO/consumerGroup.js

@@ -38,5 +38,3 @@ const Kafkajs = require("kafkajs");
 		await consumer.connect();
-		this.options.topicsToFollow.forEach(topic => {
-			await this.consumer.subscribe({ topic })
-		});
+		await Promise.all(this.options.topicsToFollow.map(topic => this.consumer.subscribe({ topic })));
 		logging.report(`Listening to kafka topics in grouped mode to the following topics: ${this.options.topicsToFollow.toString()}`);
@@ -43,0 +41,0 @@ await consumer.run({

package.json

 {
   "name": "kafka-observe",
-  "version": "2.0.1-alpha-2",
+  "version": "2.0.1-alpha-3",
   "description": "",
@@ -5,0 +5,0 @@ "main": "index.js",

No alert changes

Worsened metrics

Lines of code

327

decreased by-1.21%

No dependency changes