kafka-node - npm Package Compare versions

Comparing version 0.2.26 to 0.2.27

CHANGELOG.md

 # kafka-node CHANGELOG
 
+## 2015-05-11, Version 0.2.27
+- Deps: upgrade snappy to 3.2.0
+- Zookeeper#listConsumers: ignore error when there is no such node in zookeeper
+
 ## 2015-04-23, Version 0.2.26
@@ -4,0 +8,0 @@ - Fix: add callback to consumer.autoCommit method [#198](https://github.com/SOHU-Co/kafka-node/pull/198)

lib/client.js

@@ -89,3 +89,3 @@ 'use strict';
     this.closeBrokers(this.longpollingBrokers);
-    this.zk.client.close();
+    this.zk.close();
     cb && cb();
@@ -92,0 +92,0 @@ };

lib/zookeeper.js

@@ -253,3 +253,5 @@ 'use strict';
         function () {
-            that.listConsumers(groupId);
+            if (!that.closed) {
+                that.listConsumers(groupId);
+            }
         },
@@ -259,3 +261,6 @@ function (error, children) {
                 debug(error);
-                that.emit('error', error);
+                // Ignore NO_NODE error here #157
+                if (error.name !== 'NO_NODE') {
+                    that.emit('error', error);
+                }
             } else {
@@ -403,2 +408,7 @@ that.emit('consumersChanged');
 
+Zookeeper.prototype.close = function () {
+    this.closed = true;
+    this.client.close();
+};
+
 var ZookeeperConsumerMappings = function () {
@@ -405,0 +415,0 @@ this.consumerTopicMap = {};

package.json

 {
   "name": "kafka-node",
   "description": "node client for Apache kafka, only support kafka 0.8 and above",
-  "version": "0.2.26",
+  "version": "0.2.27",
   "main": "kafka.js",
@@ -16,3 +16,3 @@ "dependencies": {
     "retry": "~0.6.1",
-    "snappy": "~3.0.8"
+    "snappy": "^3.2.0"
   },
@@ -19,0 +19,0 @@ "devDependencies": {

README.md

@@ -41,2 +41,7 @@ Kafka-node
 
+### Events
+
+- `ready`: this event is emitted when producer is ready to send messages.
+- `error`: this is the error event propagates from internal client, producer should always listen it.
+
 ### send(payloads, cb)
@@ -120,2 +125,7 @@ * `payloads`: **Array**,array of `ProduceRequest`, `ProduceRequest` is a JSON object like:
 
+### Events
+
+- `ready`: this event is emitted when producer is ready to send messages.
+- `error`: this is the error event propagates from internal client, producer should always listen it.
+
 ### send(payloads, cb)
@@ -352,2 +362,3 @@ * `payloads`: **Array**,array of `ProduceRequest`, `ProduceRequest` is a JSON object like:
     // Auto commit config
+    autoCommit: true,
     autoCommitIntervalMs: 5000,
@@ -354,0 +365,0 @@ // The max wait time is the maximum amount of time in milliseconds to block waiting if insufficient data is available at the time the request is issued, default 100ms

No alert changes

Improved metrics

Total package byte prevSize

150259

increased by0.55%

Lines of code

3419

increased by0.26%

Number of lines in readme file

595

increased by1.88%

Dependency changes

• + Addedabbrev@1.1.1(transitive)

• + Addedansi@0.3.1(transitive)

• + Addedare-we-there-yet@1.0.6(transitive)

• + Addedasn1@0.1.11(transitive)

• + Addedassert-plus@0.1.5(transitive)

• + Addedaws-sign2@0.5.0(transitive)

• + Addedbalanced-match@1.0.2(transitive)

• + Addedbindings@1.5.0(transitive)

• + Addedbl@0.9.5(transitive)

• + Addedblock-stream@0.0.9(transitive)

• + Addedboom@0.4.2(transitive)

• + Addedbrace-expansion@1.1.11(transitive)

• + Addedcaseless@0.8.0(transitive)

• + Addedcombined-stream@0.0.7(transitive)

• + Addedconcat-map@0.0.1(transitive)

• + Addedcore-util-is@1.0.3(transitive)

• + Addedcryptiles@0.2.2(transitive)

• + Addedctype@0.5.3(transitive)

• + Addeddelayed-stream@0.0.5(transitive)

• + Addeddelegates@1.0.0(transitive)

• + Addedfile-uri-to-path@1.0.0(transitive)

• + Addedforever-agent@0.5.2(transitive)

• + Addedform-data@0.2.0(transitive)

• + Addedfstream@1.0.12(transitive)

• + Addedgauge@1.0.2(transitive)

• + Addedglob@4.3.5(transitive)

• + Addedgraceful-fs@3.0.124.2.11(transitive)

• + Addedhas-unicode@1.0.1(transitive)

• + Addedhawk@1.1.1(transitive)

• + Addedhoek@0.9.1(transitive)

• + Addedhttp-signature@0.10.1(transitive)

• + Addedinflight@1.0.6(transitive)

• + Addedinherits@2.0.4(transitive)

• + Addedisarray@0.0.11.0.0(transitive)

• + Addedjson-stringify-safe@5.0.1(transitive)

• + Addedmime-db@1.12.0(transitive)

• + Addedmime-types@1.0.22.0.14(transitive)

• + Addedminimatch@2.0.10(transitive)

• + Addedminimist@1.2.8(transitive)

• + Addedmkdirp@0.5.6(transitive)

• + Addednan@1.9.0(transitive)

• + Addednatives@1.1.6(transitive)

• + Addednopt@3.0.6(transitive)

• + Addednpmlog@1.0.0(transitive)

• + Addedoauth-sign@0.5.0(transitive)

• + Addedonce@1.4.0(transitive)

• + Addedos-homedir@1.0.2(transitive)

• + Addedos-tmpdir@1.0.2(transitive)

• + Addedosenv@0.1.5(transitive)

• + Addedpangyp@2.3.3(transitive)

• + Addedprocess-nextick-args@2.0.1(transitive)

• + Addedqs@2.3.3(transitive)

• + Addedreadable-stream@1.0.342.3.8(transitive)

• + Addedrequest@2.51.0(transitive)

• + Addedrimraf@2.2.8(transitive)

• + Addedsafe-buffer@5.1.2(transitive)

• + Addedsemver@4.3.6(transitive)

• + Addedsnappy@3.2.2(transitive)

• + Addedsntp@0.2.4(transitive)

• + Addedstring_decoder@0.10.311.1.1(transitive)

• + Addedstringstream@0.0.6(transitive)

• + Addedtar@1.0.3(transitive)

• + Addedtldts@6.1.73(transitive)

• + Addedtldts-core@6.1.73(transitive)

• + Addedtough-cookie@5.1.0(transitive)

• + Addedtunnel-agent@0.4.3(transitive)

• + Addedutil-deprecate@1.0.2(transitive)

• + Addedwhich@1.0.9(transitive)

• + Addedwrappy@1.0.2(transitive)

• - Removedbindings@1.1.1(transitive)

• - Removednan@1.7.0(transitive)

• - Removedsnappy@3.0.8(transitive)

• Updatedsnappy@^3.2.0