kafka-observe - npm Package Compare versions

Comparing version 2.1.1-beta-5 to 2.1.1-beta-6

index.js

@@ -121,3 +121,3 @@ const { Consumer, ConsumerGroup, Producer } = require("./IO");
 		*/
-		readStream: streamController.read({ producer }),
+		readStream: streamController.read({ consumer }),
 
@@ -124,0 +124,0 @@ /**

package.json

 {
   "name": "kafka-observe",
-  "version": "2.1.1-beta-5",
+  "version": "2.1.1-beta-6",
   "description": "",
@@ -23,5 +23,5 @@ "main": "index.js",
   "dependencies": {
-    "kafkajs": "^1.12.0",
-    "rxjs": "^6.5.3"
+    "kafkajs": "1.12.0",
+    "rxjs": "6.5.3"
   }
 }

README.md

@@ -130,5 +130,5 @@ # kafka-observe
 ```javascript
-const { readStream } = require("kafka-observe")(options);
+const { streamCallback } = require("kafka-observe")(options);
 
-readStream({
+streamCallback({
     topic: "topic name",
@@ -135,0 +135,0 @@ sender: "event",

No alert changes

Improved metrics

Total package byte prevSize

32049

increased by0.02%

Dependency changes

• + Addedkafkajs@1.12.0(transitive)

• + Addedlong@4.0.0(transitive)

• + Addedrxjs@6.5.3(transitive)

• - Removedkafkajs@1.16.0(transitive)

• - Removedrxjs@6.6.7(transitive)

• Updatedkafkajs@1.12.0

• Updatedrxjs@6.5.3