kafka-observe - npm Package Compare versions

Comparing version 1.0.4 to 1.0.5

index.js

@@ -50,2 +50,10 @@ const {Consumer, ConsumerGroup, Producer} = require("./IO");
 	if(enableConsumer) {
+		console.log(topicsToFollow
+			.filter(topic => topic.strategy === "All" || topic.strategy === "Both")
+			.map(topic => {
+				const newTopic = topic;
+				delete newTopic.strategy;
+				return newTopic;
+			}) || []);
+
 		consumer = new Consumer({
@@ -58,3 +66,3 @@ topicsToFollow: topicsToFollow
 					return newTopic;
-				}),
+				}) || [],
 			kafkaHost,
@@ -61,0 +69,0 @@ consumerId,

package.json

 {
   "name": "kafka-observe",
-  "version": "1.0.4",
+  "version": "1.0.5",
   "description": "",
@@ -5,0 +5,0 @@ "main": "index.js",

No alert changes

Improved metrics

Total package byte prevSize

11582

increased by1.96%

Lines of code

351

increased by2.03%

No dependency changes