kafka-observe
Advanced tools
Comparing version 2.1.1-beta-4 to 2.1.1-beta-5
@@ -121,3 +121,3 @@ const { Consumer, ConsumerGroup, Producer } = require("./IO"); | ||
*/ | ||
readStream: streamController.write({ producer }), | ||
readStream: streamController.read({ producer }), | ||
@@ -124,0 +124,0 @@ /** |
{ | ||
"name": "kafka-observe", | ||
"version": "2.1.1-beta-4", | ||
"version": "2.1.1-beta-5", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
32043