kafka-node - npm Package Compare versions

Comparing version 0.2.7 to 0.2.8

lib/client.js

@@ -69,2 +69,5 @@ 'use strict';
     });
+    zk.on('error', function (err) {
+        self.emit('error', err);
+    });
 }
@@ -71,0 +74,0 @@

lib/zookeeper.js

@@ -205,4 +205,7 @@ 'use strict';
         function (error, children) {
-            if (error)
-                return console.log('Failed to list children of node: %s due to: %s.', path, error);
+            if (error) {
+                console.log('Failed to list children of node: %s due to: %s.', path, error);
+                that.emit('error', error);
+                return;
+            }
 
@@ -212,3 +215,6 @@ if (children.length) {
                 async.each(children, getBrokerDetail, function (err) {
-                    if (err) return cb(err);
+                    if (err) {
+                        that.emit('error', error);
+                        return;
+                    }
                     if (!that.inited) {
@@ -215,0 +221,0 @@ that.emit('init', brokers);

package.json

 {
     "name": "kafka-node",
     "description": "node client for Apache kafka, only support kafka 0.8 and above",
-    "version": "0.2.7",
+    "version": "0.2.8",
     "main": "kafka.js",
@@ -6,0 +6,0 @@ "dependencies": {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

129169

increased by0.19%

Lines of code

3026

increased by0.3%

No dependency changes