kafka-observe
Advanced tools
Comparing version 1.0.5 to 1.0.6
@@ -56,4 +56,3 @@ const {Consumer, ConsumerGroup, Producer} = require("./IO"); | ||
return newTopic; | ||
}) || []); | ||
}) || []) | ||
consumer = new Consumer({ | ||
@@ -60,0 +59,0 @@ topicsToFollow: topicsToFollow |
@@ -12,2 +12,3 @@ const kafka = require("kafka-node"); | ||
this.options = options; | ||
console.log(this.options); | ||
@@ -14,0 +15,0 @@ client = new kafka.KafkaClient({ |
{ | ||
"name": "kafka-observe", | ||
"version": "1.0.5", | ||
"version": "1.0.6", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
11609
352