{"_id":"kafka-zookeeper","_rev":"33-bdd31cc41eb3879a6a4cd25369960116","name":"kafka-zookeeper","description":"A high-level client library in Node.js for the Apache Kafka project with Zookeeper integration","dist-tags":{"latest":"0.0.15"},"versions":{"0.0.1":{"name":"kafka-zookeeper","description":"A high-level client library in Node.js for the Apache Kafka project with Zookeeper integration","keywords":["kafka","producer","consumer","zookeeper","apache"],"version":"0.0.1","bugs":{"url":"https://github.com/devoncrouse/node-kafka-zookeeper/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"devoncrouse","email":"devoncrouse@gmail.com"}],"contributors":[],"dependencies":{"prozess":"0.6.x","zookeeper":"3.4.x","underscore":"1.5.x","bignum":"0.6.0"},"devDependencies":{"jscoverage":"0.3.6","coveralls":"1.1.2","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"readme":"node-kafka-zookeeper\n=======\n\nA high-level client library in Node.js for the Apache Kafka project with Zookeeper integration\n\n[Kafka](http://incubator.apache.org/kafka/index.html) is a persistent, efficient, distributed publish/subscribe messaging system.  \n[Prozess](https://github.com/cainus/Prozess) is a Kafka client library used for low-level access from node-kafka-zookeeper.\n\n##Consumer example:\n\nA `Zookeeper` object handles broker enumeration and offset storage\n```javascript\nvar Zookeeper = require('kafka-zookeeper').Zookeeper;\nvar zk = new Zookeeper({\n  host: 'kafka00.lan',\n  port: 2181\n});\n\nvar onMessages = function(messages, error, cb) {\n  if (error) return console.error(error);\n  console.log('Received %d messages', messages.length);\n\n  // true  - (Acknowledge) Update Zk offsets and continue consuming\n  // false - (Fail) Resend the same batch in 5 seconds so I don't\n  //                have to put it somewhere. TODO: configure wait\n  cb(true);\n}\n\n// Start consuming\n// TODO: Support message filter function argument\nzk.consumeTopic('MessageHeaders', 'dcrouse', onMessages);\n\n// Stop consuming\n// TODO: Implement\n\n```\n\n##Installation:\n\n  npm install kafka-zookeeper\n\n##Checkout the code and run the tests:\n\n  git clone https://github.com/devoncrouse/node-kafka-zookeeper.git  \n  cd node-kafka-zookeeper; make test-cov && open coverage.html\n\n##Kafka Compatability matrix:\n\n<table>\n  <tr>\n     <td>Kakfa 0.8.0 Release</td><td>Not Supported</td>\n  </tr>\n  <tr>\n    <td>Kafka 0.7.2 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.1 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.0 Release</td><td>Supported</td>\n  <tr>\n    <td>kafka-0.6</td><td>Consumer-only support.</td>\n  <tr>\n    <td>kafka-0.05</td><td>Not Supported</td>\n</table>\n\nVersions taken from http://incubator.apache.org/kafka/downloads.html\n","_id":"kafka-zookeeper@0.0.1","dist":{"shasum":"83129622bc4e35da9008b570dec5c9f79b91a253","tarball":"https://registry.npmjs.org/kafka-zookeeper/-/kafka-zookeeper-0.0.1.tgz","integrity":"sha512-xD9Rkuwan3HgN4gtF0T22Vql7P/HjYmBSB2huaGFFnCvp/v3mEHw5ugAXAHKYYHSTXog2YIEZ3CmD4DuukSFoA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIE9h9JnHuZDUmMVIyRUUAicyEasgMhFdDw6neZyurQnAAiEAy6vTHwsZwux22jex5h3CSZ4AOl8TlLKf7QDLJY/jgpU="}]},"_npmVersion":"1.1.63","_npmUser":{"name":"devoncrouse","email":"devoncrouse@gmail.com"}},"0.0.2":{"name":"kafka-zookeeper","description":"A high-level client library in Node.js for the Apache Kafka project with Zookeeper integration","keywords":["kafka","producer","consumer","zookeeper","apache"],"version":"0.0.2","bugs":{"url":"https://github.com/devoncrouse/node-kafka-zookeeper/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"devoncrouse","email":"devoncrouse@gmail.com"}],"contributors":[],"dependencies":{"prozess":"0.6.x","zookeeper":"3.4.x","winston":"0.7.x","underscore":"1.5.x","bignum":"0.6.x"},"devDependencies":{"jscoverage":"0.3.6","coveralls":"1.1.2","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"readme":"node-kafka-zookeeper\n=======\n\nA high-level client library in Node.js for the Apache Kafka project with Zookeeper integration\n\n[Kafka](http://incubator.apache.org/kafka/index.html) is a persistent, efficient, distributed publish/subscribe messaging system.  \n[Prozess](https://github.com/cainus/Prozess) is a Kafka client library used for low-level access from node-kafka-zookeeper.\n\n##Consumer example:\n\nA `Zookeeper` object handles broker enumeration and offset storage\n```javascript\nvar Zookeeper = require('kafka-zookeeper').Zookeeper;\nvar zk = new Zookeeper({\n  host: 'kafka00.lan',\n  port: 2181\n});\n\nvar onMessages = function(messages, error, cb) {\n  if (error) return console.error(error);\n  console.log('Received %d messages', messages.length);\n\n  // true  - (Acknowledge) Update Zk offsets and continue consuming\n  // false - (Fail) Resend the same batch in 5 seconds so I don't\n  //                have to put it somewhere. TODO: configure wait\n  cb(true);\n}\n\n// Start consuming\n// TODO: Support message filter function argument\nzk.consumeTopic('MessageHeaders', 'dcrouse', onMessages);\n\n// Stop consuming\n// TODO: Implement\n\n```\n\n##Installation:\n\n  npm install kafka-zookeeper\n\n##Checkout the code and run the tests:\n\n  git clone https://github.com/devoncrouse/node-kafka-zookeeper.git  \n  cd node-kafka-zookeeper; make test-cov && open coverage.html\n\n##Kafka Compatability matrix:\n\n<table>\n  <tr>\n     <td>Kakfa 0.8.0 Release</td><td>Not Supported</td>\n  </tr>\n  <tr>\n    <td>Kafka 0.7.2 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.1 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.0 Release</td><td>Supported</td>\n  <tr>\n    <td>kafka-0.6</td><td>Consumer-only support.</td>\n  <tr>\n    <td>kafka-0.05</td><td>Not Supported</td>\n</table>\n\nVersions taken from http://incubator.apache.org/kafka/downloads.html\n","_id":"kafka-zookeeper@0.0.2","dist":{"shasum":"a57055d1764cde53b6315c9a9949e91e6a6a8a33","tarball":"https://registry.npmjs.org/kafka-zookeeper/-/kafka-zookeeper-0.0.2.tgz","integrity":"sha512-JLVhEA46exIgnAMcRKb8K0ulzBK/Xgzr/LsyNqXk8xakhMGRKIgE4mrb9U4ggCICK1zlrpdBhJdmTivzqifhGA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDp+4sZ1i1RTcHC1P8HV7bNYBYjh8xGBJlRfvR8756jhAIgGHc0SLQ0rO6NzabvAewm7ENopeVo3mIWLElpn+g8+HE="}]},"_npmVersion":"1.1.63","_npmUser":{"name":"devoncrouse","email":"devoncrouse@gmail.com"}},"0.0.3":{"name":"kafka-zookeeper","description":"A high-level client library in Node.js for the Apache Kafka project with Zookeeper integration","keywords":["kafka","producer","consumer","zookeeper","apache"],"version":"0.0.3","bugs":{"url":"https://github.com/devoncrouse/node-kafka-zookeeper/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"devoncrouse","email":"devoncrouse@gmail.com"}],"contributors":[],"dependencies":{"prozess":"0.6.x","zookeeper":"3.4.x","winston":"0.7.x","underscore":"1.5.x","bignum":"0.6.x"},"devDependencies":{"jscoverage":"0.3.6","coveralls":"1.1.2","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"readme":"node-kafka-zookeeper\n=======\n\nA high-level client library in Node.js for the Apache Kafka project with Zookeeper integration\n\n[Kafka](http://incubator.apache.org/kafka/index.html) is a persistent, efficient, distributed publish/subscribe messaging system.  \n[Prozess](https://github.com/cainus/Prozess) is a Kafka client library used for low-level access from node-kafka-zookeeper.\n\n##Consumer example:\n\nA `Zookeeper` object handles broker enumeration and offset storage\n```javascript\nvar Zookeeper = require('kafka-zookeeper').Zookeeper;\nvar zk = new Zookeeper({\n  host: 'kafka00.lan',\n  port: 2181\n});\n\nvar onMessages = function(messages, error, cb) {\n  if (error) return console.error(error);\n  console.log('Received %d messages', messages.length);\n\n  // true  - (Acknowledge) Update Zk offsets and continue consuming\n  // false - (Fail) Resend the same batch in 5 seconds so I don't\n  //                have to put it somewhere. TODO: configure wait\n  cb(true);\n}\n\n// Start consuming\n// TODO: Support message filter function argument\nzk.consumeTopic('MessageHeaders', 'dcrouse', onMessages);\n\n// Stop consuming\n// TODO: Implement\n\n```\n\n##Installation:\n\n  npm install kafka-zookeeper\n\n##Checkout the code and run the tests:\n\n  git clone https://github.com/devoncrouse/node-kafka-zookeeper.git  \n  cd node-kafka-zookeeper; make test-cov && open coverage.html\n\n##Kafka Compatability matrix:\n\n<table>\n  <tr>\n     <td>Kakfa 0.8.0 Release</td><td>Not Supported</td>\n  </tr>\n  <tr>\n    <td>Kafka 0.7.2 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.1 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.0 Release</td><td>Supported</td>\n  <tr>\n    <td>kafka-0.6</td><td>Consumer-only support.</td>\n  <tr>\n    <td>kafka-0.05</td><td>Not Supported</td>\n</table>\n\nVersions taken from http://incubator.apache.org/kafka/downloads.html\n","_id":"kafka-zookeeper@0.0.3","dist":{"shasum":"e6e2a492b6d0fc6b7967a0d61aa510105ed5d33e","tarball":"https://registry.npmjs.org/kafka-zookeeper/-/kafka-zookeeper-0.0.3.tgz","integrity":"sha512-Xw0cawixpQ7B6/Fvey4KqDj/KwJL23z1uOtDzImVYzmPnOMA0M9FK+Fj4FKtD2t+t4/SIKnndvmTYVyUxZM4FQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDrVWXA/Mu+lZZmfY8o6NuPZBYwxmlgbFhRyKHEGqm9ZAIgDw4xRNy7Dvgfz5f0hoo8yXfcbG+vU+1HcH+7Rod3VM8="}]},"_npmVersion":"1.1.63","_npmUser":{"name":"devoncrouse","email":"devoncrouse@gmail.com"}},"0.0.4":{"name":"kafka-zookeeper","description":"A high-level client library in Node.js for the Apache Kafka project with Zookeeper integration","keywords":["kafka","producer","consumer","zookeeper","apache"],"version":"0.0.4","bugs":{"url":"https://github.com/devoncrouse/node-kafka-zookeeper/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"devoncrouse","email":"devoncrouse@gmail.com"}],"contributors":[],"engines":{"node":">=0.8"},"dependencies":{"prozess":"0.6.x","zookeeper":"3.4.x","optimist":"0.6.x","winston":"0.7.x","underscore":"1.5.x","bignum":"0.6.x"},"devDependencies":{"jscoverage":"0.3.x","coveralls":"1.1.x","mockery":"1.1.x","hottap":"1.0.x","mocha":"1.3.x","should":"1.1.x","sinon":"1.5.x"},"readme":"node-kafka-zookeeper\n=======\n\nA high-level client library in Node.js for the Apache Kafka project with Zookeeper integration\n\n[Kafka](http://incubator.apache.org/kafka/index.html) is a persistent, efficient, distributed publish/subscribe messaging system.  \n[Prozess](https://github.com/cainus/Prozess) is a Kafka client library used for low-level access from node-kafka-zookeeper.\n\n###Consumer example:\n\nA `Zookeeper` object handles broker enumeration and offset storage\n```javascript\nvar Zookeeper = require('kafka-zookeeper').Zookeeper;\nvar zk = new Zookeeper({\n  host: 'kafka00.lan',\n  port: 2181\n});\n\nvar onMessages = function(messages, error, cb) {\n  if (error) return console.error(error);\n  console.log('Received %d messages', messages.length);\n\n  // true  - (Acknowledge) Update Zk offsets and continue consuming\n  // false - (Fail) Resend the same batch in 5 seconds so I don't\n  //                have to put it somewhere. TODO: configure wait\n  cb(true);\n}\n\n// Start consuming\n// TODO: Support message filter function argument\nzk.consumeTopic('MessageHeaders', 'dcrouse', onMessages);\n\n// Stop consuming\n// TODO: Implement\n\n```\n\n###Installation:\n\n  npm install kafka-zookeeper\n\n###Checkout the code and run the tests:\n\n  git clone https://github.com/devoncrouse/node-kafka-zookeeper.git  \n  cd node-kafka-zookeeper; make test-cov && open coverage.html\n\n###Kafka Compatability matrix:\n\n<table>\n  <tr>\n     <td>Kakfa 0.8.0 Release</td><td>Not Supported</td>\n  </tr>\n  <tr>\n    <td>Kafka 0.7.2 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.1 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.0 Release</td><td>Supported</td>\n  <tr>\n    <td>kafka-0.6</td><td>Consumer-only support.</td>\n  <tr>\n    <td>kafka-0.05</td><td>Not Supported</td>\n</table>\n\nVersions taken from http://incubator.apache.org/kafka/downloads.html\n","_id":"kafka-zookeeper@0.0.4","dist":{"shasum":"de3a2caac17e173dc4a59a7b58cff06804b422b4","tarball":"https://registry.npmjs.org/kafka-zookeeper/-/kafka-zookeeper-0.0.4.tgz","integrity":"sha512-LJmMq59IVpHSGR+oFTM81oM+ux6CGCPTUNm3wuaCpbhc+gKg2gTdcnAQe/qEzg1jiZkmiG5EKXnCgQmEBk0WTw==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIDKdgEHFPtS5fJr8tUji5fnlCoVP3QmfeL2NgvIP0pS8AiEAhTLm7i01Ea0VMmi9Xek7HDDt4PdkmXRxXbzRXJv6Tnc="}]},"_npmVersion":"1.1.63","_npmUser":{"name":"devoncrouse","email":"devoncrouse@gmail.com"}},"0.0.5":{"name":"kafka-zookeeper","description":"A high-level client library in Node.js for the Apache Kafka project with Zookeeper integration","keywords":["kafka","producer","consumer","zookeeper","apache"],"version":"0.0.5","bugs":{"url":"https://github.com/devoncrouse/node-kafka-zookeeper/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"devoncrouse","email":"devoncrouse@gmail.com"}],"contributors":[],"engines":{"node":">=0.8"},"dependencies":{"prozess":"0.6.x","zookeeper":"3.4.x","optimist":"0.6.x","winston":"0.7.x","underscore":"1.5.x","bignum":"0.6.x"},"devDependencies":{"jscoverage":"0.3.x","coveralls":"1.1.x","mockery":"1.1.x","hottap":"1.0.x","mocha":"1.3.x","should":"1.1.x","sinon":"1.5.x"},"readme":"node-kafka-zookeeper\n=======\n\nA high-level client library in Node.js for the Apache Kafka project with Zookeeper integration\n\n[Kafka](http://incubator.apache.org/kafka/index.html) is a persistent, efficient, distributed publish/subscribe messaging system.  \n[Prozess](https://github.com/cainus/Prozess) is a Kafka client library used for low-level access from node-kafka-zookeeper.\n\n###Consumer example:\n\nA `Zookeeper` object handles broker enumeration and offset storage\n```javascript\nvar Zookeeper = require('kafka-zookeeper').Zookeeper;\nvar zk = new Zookeeper({\n  host: 'kafka00.lan',\n  port: 2181\n});\n\nvar onMessages = function(messages, error, cb) {\n  if (error) return console.error(error);\n  console.log('Received %d messages', messages.length);\n\n  // true  - (Acknowledge) Update Zk offsets and continue consuming\n  // false - (Fail) Resend the same batch in 5 seconds so I don't\n  //                have to put it somewhere. TODO: configure wait\n  cb(true);\n}\n\n// Start consuming\n// TODO: Support message filter function argument\nzk.consumeTopic('MessageHeaders', 'dcrouse', onMessages);\n\n// Stop consuming\n// TODO: Implement\n\n```\n\n###Installation:\n\n  npm install kafka-zookeeper\n\n###Checkout the code and run the tests:\n\n  git clone https://github.com/devoncrouse/node-kafka-zookeeper.git  \n  cd node-kafka-zookeeper; make test-cov && open coverage.html\n\n###Kafka Compatability matrix:\n\n<table>\n  <tr>\n     <td>Kakfa 0.8.0 Release</td><td>Not Supported</td>\n  </tr>\n  <tr>\n    <td>Kafka 0.7.2 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.1 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.0 Release</td><td>Supported</td>\n  <tr>\n    <td>kafka-0.6</td><td>Consumer-only support.</td>\n  <tr>\n    <td>kafka-0.05</td><td>Not Supported</td>\n</table>\n\nVersions taken from http://incubator.apache.org/kafka/downloads.html\n","_id":"kafka-zookeeper@0.0.5","dist":{"shasum":"c14999841337740224eb9cbc4e102a7992f90c2d","tarball":"https://registry.npmjs.org/kafka-zookeeper/-/kafka-zookeeper-0.0.5.tgz","integrity":"sha512-94YNJBRfUS+Qt1JIZjKzZhuEq3hPM1hKSvyD6XMa8MNJqDq0RFpIWsUjua9J2iaFuru+d0p2LQiMykct2NRJzQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIA2AK2MeJabduwsTHdPwqtCiipOVvedqmD8hZsQlsIn5AiAlqq1wYl36qGPnsondWm0FgyhYVWgfXh7/rC8z8jU+yQ=="}]},"_npmVersion":"1.1.63","_npmUser":{"name":"devoncrouse","email":"devoncrouse@gmail.com"}},"0.0.6":{"name":"kafka-zookeeper","description":"A high-level client library in Node.js for the Apache Kafka project with Zookeeper integration","keywords":["kafka","producer","consumer","zookeeper","apache"],"version":"0.0.6","bugs":{"url":"https://github.com/devoncrouse/node-kafka-zookeeper/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"devoncrouse","email":"devoncrouse@gmail.com"}],"contributors":[],"engines":{"node":">=0.8"},"dependencies":{"prozess":"0.6.x","zookeeper":"3.4.x","optimist":"0.6.x","winston":"0.7.x","underscore":"1.5.x","bignum":"0.6.x"},"devDependencies":{"jscoverage":"0.3.x","coveralls":"1.1.x","mockery":"1.1.x","hottap":"1.0.x","mocha":"1.3.x","should":"1.1.x","sinon":"1.5.x"},"readme":"node-kafka-zookeeper\n=======\n\nA high-level client library in Node.js for the Apache Kafka project with Zookeeper integration\n\n[Kafka](http://incubator.apache.org/kafka/index.html) is a persistent, efficient, distributed publish/subscribe messaging system.  \n[Prozess](https://github.com/cainus/Prozess) is a Kafka client library used for low-level access from node-kafka-zookeeper.\n\n###Consumer example:\n\nA `Zookeeper` object handles broker enumeration and offset storage\n```javascript\nvar Zookeeper = require('kafka-zookeeper').Zookeeper;\nvar zk = new Zookeeper({\n  host: 'kafka00.lan',\n  port: 2181\n});\n\nvar onMessages = function(messages, error, cb) {\n  if (error) return console.error(error);\n  console.log('Received %d messages', messages.length);\n\n  // true  - (Acknowledge) Update Zk offsets and continue consuming\n  // false - (Fail) Resend the same batch in 5 seconds so I don't\n  //                have to put it somewhere. TODO: configure wait\n  cb(true);\n}\n\n// Start consuming\n// TODO: Support message filter function argument\nzk.consumeTopic('MessageHeaders', 'dcrouse', onMessages);\n\n// Stop consuming\n// TODO: Implement\n\n```\n\n###Installation:\n\n  npm install kafka-zookeeper\n\n###Checkout the code and run the tests:\n\n  git clone https://github.com/devoncrouse/node-kafka-zookeeper.git  \n  cd node-kafka-zookeeper; make test-cov && open coverage.html\n\n###Kafka Compatability matrix:\n\n<table>\n  <tr>\n     <td>Kakfa 0.8.0 Release</td><td>Not Supported</td>\n  </tr>\n  <tr>\n    <td>Kafka 0.7.2 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.1 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.0 Release</td><td>Supported</td>\n  <tr>\n    <td>kafka-0.6</td><td>Consumer-only support.</td>\n  <tr>\n    <td>kafka-0.05</td><td>Not Supported</td>\n</table>\n\nVersions taken from http://incubator.apache.org/kafka/downloads.html\n","_id":"kafka-zookeeper@0.0.6","dist":{"shasum":"f8eb44a296fc749c3061058257e72d081e9ebf50","tarball":"https://registry.npmjs.org/kafka-zookeeper/-/kafka-zookeeper-0.0.6.tgz","integrity":"sha512-iaE6e3imJjj9A7HC+iAAA0nkYvfbWQeaJFIIaFV3TkCMk7p3Ycn0Mz7DB5aM7cj8Csm5IIVV5/cFKEwloUciaw==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDubAogIyra2zeXfzNhC0i/Ar2bp2YJWM9O74VwAou/SQIgfc2jjSKBILX+EBBYVg3TX0IyI/rgTrkOManycnvyu9I="}]},"_npmVersion":"1.1.63","_npmUser":{"name":"devoncrouse","email":"devoncrouse@gmail.com"}},"0.0.7":{"name":"kafka-zookeeper","description":"A high-level client library in Node.js for the Apache Kafka project with Zookeeper integration","keywords":["kafka","producer","consumer","zookeeper","apache"],"version":"0.0.7","bugs":{"url":"https://github.com/devoncrouse/node-kafka-zookeeper/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"devoncrouse","email":"devoncrouse@gmail.com"}],"contributors":[],"engines":{"node":">=0.8"},"dependencies":{"prozess":"0.6.x","zookeeper":"3.4.x","optimist":"0.6.x","winston":"0.7.x","underscore":"1.5.x","bignum":"0.6.x","async":"0.2.x"},"devDependencies":{"jscoverage":"0.3.x","coveralls":"1.1.x","mockery":"1.1.x","hottap":"1.0.x","mocha":"1.3.x","should":"1.1.x","sinon":"1.5.x"},"readme":"node-kafka-zookeeper\n=======\n\nA high-level client library in Node.js for the Apache Kafka project with Zookeeper integration\n\n[Kafka](http://incubator.apache.org/kafka/index.html) is a persistent, efficient, distributed publish/subscribe messaging system.  \n[Prozess](https://github.com/cainus/Prozess) is a Kafka client library used for low-level access from node-kafka-zookeeper.\n\n###Consumer example:\n\nA `Zookeeper` object handles broker enumeration and offset storage\n```javascript\nvar Zookeeper = require('kafka-zookeeper').Zookeeper;\nvar zk = new Zookeeper({\n  host: 'kafka00.lan',\n  port: 2181\n});\n\nvar onMessages = function(messages, error, cb) {\n  if (error) return console.error(error);\n  console.log('Received %d messages', messages.length);\n\n  // true  - (Acknowledge) Update Zk offsets and continue consuming\n  // false - (Fail) Resend the same batch in 5 seconds so I don't\n  //                have to put it somewhere. TODO: configure wait\n  cb(true);\n}\n\n// Start consuming\n// TODO: Support message filter function argument\nzk.consumeTopic('MessageHeaders', 'dcrouse', onMessages);\n\n// Stop consuming\n// TODO: Implement\n\n```\n\n###Utility examples:\n\nThe `Zookeeper` object also exposes some utility functions - used internally and useful for testing\n```javascript\nvar _ = require('underscore');\nvar Zookeeper = require('../lib/Zookeeper');\n\nvar zk = new Zookeeper({\n  host: 'localhost',\n  port: 2181\n});\n\nvar topic = 'KafkaTopic', group = 'ConsumerGroup';\n\n// Retrieve all consumer offsets for topic/group\nvar onConsumerOffsets = function(offsets, error) {\n  if (error) return console.error('onConsumerOffsets', error);\n  console.log('Offsets', offsets);\n};\n\nzk.getConsumerOffsets(topic, group, onConsumerOffsets);\n\n// Initialize consumer offsets\nvar onInitializeConsumerOffsets = function(error) {\n  if (error) return console.error('onInitializeConsumerOffsets', error);\n  console.log('Consumer offsets initialized');\n};\n\nzk.initializeConsumerOffsets(topic, group, onInitializeConsumerOffsets);\n```\n\n###Installation:\n\n  npm install kafka-zookeeper\n\n###Checkout the code and run the tests:\n\n  git clone https://github.com/devoncrouse/node-kafka-zookeeper.git  \n  cd node-kafka-zookeeper; make test-cov && open coverage.html\n\n###Kafka Compatability matrix:\n\n<table>\n  <tr>\n     <td>Kakfa 0.8.0 Release</td><td>Not Supported</td>\n  </tr>\n  <tr>\n    <td>Kafka 0.7.2 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.1 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.0 Release</td><td>Supported</td>\n  <tr>\n    <td>kafka-0.6</td><td>Consumer-only support.</td>\n  <tr>\n    <td>kafka-0.05</td><td>Not Supported</td>\n</table>\n\nVersions taken from http://incubator.apache.org/kafka/downloads.html\n","_id":"kafka-zookeeper@0.0.7","dist":{"shasum":"6f504d8a6cb21b3cfa2bbaaaaac804f8f2a4c1bc","tarball":"https://registry.npmjs.org/kafka-zookeeper/-/kafka-zookeeper-0.0.7.tgz","integrity":"sha512-d4ag650TSBs++/ztlsEaNC4KbVDhPvfPDy0J+j+hpkWy2m4eE9gQrWGJX2KAN6Mx5Ij9gPoA6gGrYUkdG+jf3w==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIFR5Pmsb5jerUIecx4VhXRN1hCA9em1c+Cb72YsN6COgAiEApjhBXC5XYRfF2Foey0C5X7Cc65ElRQ4fETHt+YnK8Eo="}]},"_npmVersion":"1.1.63","_npmUser":{"name":"devoncrouse","email":"devoncrouse@gmail.com"}},"0.0.8":{"name":"kafka-zookeeper","description":"A high-level client library in Node.js for the Apache Kafka project with Zookeeper integration","keywords":["kafka","producer","consumer","zookeeper","apache"],"version":"0.0.8","bugs":{"url":"https://github.com/devoncrouse/node-kafka-zookeeper/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"devoncrouse","email":"devoncrouse@gmail.com"}],"contributors":[],"engines":{"node":">=0.8"},"dependencies":{"prozess":"0.6.x","zookeeper":"3.4.x","optimist":"0.6.x","winston":"0.7.x","underscore":"1.5.x","underscore.string":"2.3.x","bignum":"0.6.x","async":"0.2.x"},"devDependencies":{"jscoverage":"0.3.x","coveralls":"1.1.x","mockery":"1.4.x","hottap":"1.0.x","mocha":"1.3.x","should":"1.1.x","sinon":"1.5.x"},"readme":"node-kafka-zookeeper\n=======\n\nA high-level client library in Node.js for the Apache Kafka project with Zookeeper integration\n\n[Kafka](http://incubator.apache.org/kafka/index.html) is a persistent, efficient, distributed publish/subscribe messaging system.  \n[Prozess](https://github.com/cainus/Prozess) is a Kafka client library used for low-level access from node-kafka-zookeeper.\n\n###Consumer example:\n\nA `Zookeeper` object handles broker enumeration and offset storage\n```javascript\nvar Zookeeper = require('kafka-zookeeper').Zookeeper;\nvar zk = new Zookeeper({\n  host: 'kafka00.lan',\n  port: 2181\n});\n\nvar onMessages = function(messages, error, cb) {\n  if (error) return console.error(error);\n  console.log('Received %d messages', messages.length);\n\n  // true  - (Acknowledge) Update Zk offsets and continue consuming\n  // false - (Fail) Resend the same batch in 5 seconds so I don't\n  //                have to put it somewhere. TODO: configure wait\n  cb(true);\n}\n\n// Start consuming\n// TODO: Support message filter function argument\nzk.consumeTopic('MessageHeaders', 'dcrouse', onMessages);\n\n// Stop consuming\n// TODO: Implement\n\n```\n\n###Utility examples:\n\nThe `Zookeeper` object also exposes some utility functions - used internally and useful for testing\n```javascript\nvar _ = require('underscore');\nvar Zookeeper = require('../lib/Zookeeper');\n\nvar zk = new Zookeeper({\n  host: 'localhost',\n  port: 2181\n});\n\nvar topic = 'KafkaTopic', group = 'ConsumerGroup';\n\n// Retrieve all consumer offsets for topic/group\nvar onConsumerOffsets = function(offsets, error) {\n  if (error) return console.error('onConsumerOffsets', error);\n  console.log('Offsets', offsets);\n};\n\nzk.getConsumerOffsets(topic, group, onConsumerOffsets);\n\n// Initialize consumer offsets\nvar onInitializeConsumerOffsets = function(error) {\n  if (error) return console.error('onInitializeConsumerOffsets', error);\n  console.log('Consumer offsets initialized');\n};\n\nzk.initializeConsumerOffsets(topic, group, onInitializeConsumerOffsets);\n```\n\n###Installation:\n\n  npm install kafka-zookeeper\n\n###Checkout the code and run the tests:\n\n  git clone https://github.com/devoncrouse/node-kafka-zookeeper.git  \n  cd node-kafka-zookeeper; make test-cov && open coverage.html\n\n###Kafka Compatability matrix:\n\n<table>\n  <tr>\n     <td>Kakfa 0.8.0 Release</td><td>Not Supported</td>\n  </tr>\n  <tr>\n    <td>Kafka 0.7.2 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.1 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.0 Release</td><td>Supported</td>\n  <tr>\n    <td>kafka-0.6</td><td>Consumer-only support.</td>\n  <tr>\n    <td>kafka-0.05</td><td>Not Supported</td>\n</table>\n\nVersions taken from http://incubator.apache.org/kafka/downloads.html\n","readmeFilename":"README.md","_id":"kafka-zookeeper@0.0.8","dist":{"shasum":"94700d68944b523c013fff140964442af2d09359","tarball":"https://registry.npmjs.org/kafka-zookeeper/-/kafka-zookeeper-0.0.8.tgz","integrity":"sha512-4RyAOgM265cS212YE2vkQEqnnfdAwvnXVpPZYLszr7/bpWT+BBPE4Cu3xtx/FVyee2orLG0i6dF9JaaiAGjLxQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDjFWLI9GoTWuvSgt/QcbXGWbsfsaJbcESDANyysmYpNAIhAOXvYNIJtqTjtzSUn8IzA9GKyppCyzUxlWOvNmHwJp+w"}]},"_from":"kafka-zookeeper@0.x.x","_resolved":"https://registry.npmjs.org/kafka-zookeeper/-/kafka-zookeeper-0.0.7.tgz","_npmVersion":"1.1.63","_npmUser":{"name":"devoncrouse","email":"devoncrouse@gmail.com"}},"0.0.9":{"name":"kafka-zookeeper","description":"A high-level client library in Node.js for the Apache Kafka project with Zookeeper integration","keywords":["kafka","producer","consumer","zookeeper","apache"],"version":"0.0.9","bugs":{"url":"https://github.com/devoncrouse/node-kafka-zookeeper/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"devoncrouse","email":"devoncrouse@gmail.com"}],"contributors":[],"engines":{"node":">=0.8"},"dependencies":{"prozess":"0.6.x","zookeeper":"3.4.x","optimist":"0.6.x","winston":"0.7.x","underscore":"1.5.x","underscore.string":"2.3.x","bignum":"0.6.x","async":"0.2.x"},"devDependencies":{"jscoverage":"0.3.x","coveralls":"1.1.x","mockery":"1.4.x","hottap":"1.0.x","mocha":"1.3.x","should":"1.1.x","sinon":"1.5.x"},"readme":"node-kafka-zookeeper\n=======\n\nA high-level client library in Node.js for the Apache Kafka project with Zookeeper integration\n\n[Kafka](http://incubator.apache.org/kafka/index.html) is a persistent, efficient, distributed publish/subscribe messaging system.  \n[Prozess](https://github.com/cainus/Prozess) is a Kafka client library used for low-level access from node-kafka-zookeeper.\n\n###Consumer example:\n\nA `Zookeeper` object handles broker enumeration and offset storage\n```javascript\nvar Zookeeper = require('kafka-zookeeper').Zookeeper;\nvar zk = new Zookeeper({\n  host: 'kafka00.lan',\n  port: 2181\n});\n\nvar onMessages = function(messages, error, cb) {\n  if (error) return console.error(error);\n  console.log('Received %d messages', messages.length);\n\n  // true  - (Acknowledge) Update Zk offsets and continue consuming\n  // false - (Fail) Resend the same batch in 5 seconds so I don't\n  //                have to put it somewhere. TODO: configure wait\n  cb(true);\n}\n\n// Start consuming\n// TODO: Support message filter function argument\nzk.consumeTopic('MessageHeaders', 'dcrouse', onMessages);\n\n// Stop consuming\n// TODO: Implement\n\n```\n\n###Utility examples:\n\nThe `Zookeeper` object also exposes some utility functions - used internally and useful for testing\n```javascript\nvar _ = require('underscore');\nvar Zookeeper = require('../lib/Zookeeper');\n\nvar zk = new Zookeeper({\n  host: 'localhost',\n  port: 2181\n});\n\nvar topic = 'KafkaTopic', group = 'ConsumerGroup';\n\n// Retrieve all consumer offsets for topic/group\nvar onConsumerOffsets = function(offsets, error) {\n  if (error) return console.error('onConsumerOffsets', error);\n  console.log('Offsets', offsets);\n};\n\nzk.getConsumerOffsets(topic, group, onConsumerOffsets);\n\n// Initialize consumer offsets\nvar onInitializeConsumerOffsets = function(error) {\n  if (error) return console.error('onInitializeConsumerOffsets', error);\n  console.log('Consumer offsets initialized');\n};\n\nzk.initializeConsumerOffsets(topic, group, onInitializeConsumerOffsets);\n```\n\n###Installation:\n\n  npm install kafka-zookeeper\n\n###Checkout the code and run the tests:\n\n  git clone https://github.com/devoncrouse/node-kafka-zookeeper.git  \n  cd node-kafka-zookeeper; make test-cov && open coverage.html\n\n###Kafka Compatability matrix:\n\n<table>\n  <tr>\n     <td>Kakfa 0.8.0 Release</td><td>Not Supported</td>\n  </tr>\n  <tr>\n    <td>Kafka 0.7.2 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.1 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.0 Release</td><td>Supported</td>\n  <tr>\n    <td>kafka-0.6</td><td>Consumer-only support.</td>\n  <tr>\n    <td>kafka-0.05</td><td>Not Supported</td>\n</table>\n\nVersions taken from http://incubator.apache.org/kafka/downloads.html\n","_id":"kafka-zookeeper@0.0.9","dist":{"shasum":"9240e22ebd0031c4936c4228c858153ecc394f5f","tarball":"https://registry.npmjs.org/kafka-zookeeper/-/kafka-zookeeper-0.0.9.tgz","integrity":"sha512-Hoan5S1G7RVGBAgQ4jgeQyLYWBarrAyOcnDsEo/bGLO/VcFii5sFQX53ZBpDTFnjvRoRKQQJhAZpsmIbh2O9bA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIBcCZYzCRo5QkS4FpSBxD3t8LtJzLRWd15AYdsTxgcL+AiEA0u0/b1HFwZkUz1+QChSVL8FYqoUxr28YjD+WQBvjGps="}]},"_npmVersion":"1.1.63","_npmUser":{"name":"devoncrouse","email":"devoncrouse@gmail.com"}},"0.0.10":{"name":"kafka-zookeeper","description":"A high-level client library in Node.js for the Apache Kafka project with Zookeeper integration","keywords":["kafka","producer","consumer","zookeeper","apache"],"version":"0.0.10","bugs":{"url":"https://github.com/devoncrouse/node-kafka-zookeeper/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"devoncrouse","email":"devoncrouse@gmail.com"}],"contributors":[],"engines":{"node":">=0.8"},"dependencies":{"prozess":"0.6.x","zookeeper":"3.4.x","optimist":"0.6.x","winston":"0.7.x","underscore":"1.5.x","underscore.string":"2.3.x","bignum":"0.6.x","async":"0.2.x"},"devDependencies":{"jscoverage":"0.3.x","coveralls":"1.1.x","mockery":"1.4.x","hottap":"1.0.x","mocha":"1.3.x","should":"1.1.x","sinon":"1.5.x","buffermaker":"0.0.x"},"readme":"node-kafka-zookeeper\n=======\n\nA high-level client library in Node.js for the Apache Kafka project with Zookeeper integration\n\n[Kafka](http://incubator.apache.org/kafka/index.html) is a persistent, efficient, distributed publish/subscribe messaging system.  \n[Prozess](https://github.com/cainus/Prozess) is a Kafka client library used for low-level access from node-kafka-zookeeper.\n\n###Consumer example:\n\nA `Zookeeper` object handles broker enumeration and offset storage\n```javascript\nvar Zookeeper = require('kafka-zookeeper').Zookeeper;\nvar zk = new Zookeeper({\n  host: 'kafka00.lan',\n  port: 2181\n});\n\nvar onMessages = function(messages, error, cb) {\n  if (error) return console.error(error);\n  console.log('Received %d messages', messages.length);\n\n  // true  - (Acknowledge) Update Zk offsets and continue consuming\n  // false - (Fail) Resend the same batch in 5 seconds so I don't\n  //                have to put it somewhere. TODO: configure wait\n  cb(true);\n}\n\n// Start consuming\n// TODO: Support message filter function argument\nzk.consumeTopic('MessageHeaders', 'dcrouse', onMessages);\n\n// Stop consuming\n// TODO: Implement\n\n```\n\n###Utility examples:\n\nThe `Zookeeper` object also exposes some utility functions - used internally and useful for testing\n```javascript\nvar _ = require('underscore');\nvar Zookeeper = require('../lib/Zookeeper');\n\nvar zk = new Zookeeper({\n  host: 'localhost',\n  port: 2181\n});\n\nvar topic = 'KafkaTopic', group = 'ConsumerGroup';\n\n// Retrieve all consumer offsets for topic/group\nvar onConsumerOffsets = function(offsets, error) {\n  if (error) return console.error('onConsumerOffsets', error);\n  console.log('Offsets', offsets);\n};\n\nzk.getConsumerOffsets(topic, group, onConsumerOffsets);\n\n// Initialize consumer offsets\nvar onInitializeConsumerOffsets = function(error) {\n  if (error) return console.error('onInitializeConsumerOffsets', error);\n  console.log('Consumer offsets initialized');\n};\n\nzk.initializeConsumerOffsets(topic, group, onInitializeConsumerOffsets);\n```\n\n###Installation:\n\n  npm install kafka-zookeeper\n\n###Checkout the code and run the tests:\n\n  git clone https://github.com/devoncrouse/node-kafka-zookeeper.git  \n  cd node-kafka-zookeeper; make test-cov && open coverage.html\n\n###Kafka Compatability matrix:\n\n<table>\n  <tr>\n     <td>Kakfa 0.8.0 Release</td><td>Not Supported</td>\n  </tr>\n  <tr>\n    <td>Kafka 0.7.2 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.1 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.0 Release</td><td>Supported</td>\n  <tr>\n    <td>kafka-0.6</td><td>Consumer-only support.</td>\n  <tr>\n    <td>kafka-0.05</td><td>Not Supported</td>\n</table>\n\nVersions taken from http://incubator.apache.org/kafka/downloads.html\n","_id":"kafka-zookeeper@0.0.10","dist":{"shasum":"3a108fc4eb1ba3947a48b7ceee83b7b25891038a","tarball":"https://registry.npmjs.org/kafka-zookeeper/-/kafka-zookeeper-0.0.10.tgz","integrity":"sha512-nCTBvGVg5upiPsSTnGB5N9fTIP3PR30nvRyjSh14RA1exJ6J7LfjEiWgA8PLW+6y6OgVdIB+nnIiWB0fVbygSQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIFAA4qiQr0ButXaYhzeCpV8Ir0KRihcnKLLVnDwrHI8AAiEApw1TzMSq+c0ebsM8I5a81bHsUj+k3M0JrPVNsy2wFTw="}]},"_npmVersion":"1.1.63","_npmUser":{"name":"devoncrouse","email":"devoncrouse@gmail.com"}},"0.0.11":{"name":"kafka-zookeeper","description":"A high-level client library in Node.js for the Apache Kafka project with Zookeeper integration","keywords":["kafka","producer","consumer","zookeeper","apache"],"version":"0.0.11","bugs":{"url":"https://github.com/devoncrouse/node-kafka-zookeeper/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"devoncrouse","email":"devoncrouse@gmail.com"}],"contributors":[],"engines":{"node":">=0.8"},"dependencies":{"prozess":"0.6.x","zookeeper":"3.4.x","optimist":"0.6.x","winston":"0.7.x","underscore":"1.5.x","underscore.string":"2.3.x","bignum":"0.6.x","async":"0.2.x"},"devDependencies":{"jscoverage":"0.3.x","coveralls":"1.1.x","mockery":"1.4.x","hottap":"1.0.x","mocha":"1.3.x","should":"1.1.x","sinon":"1.5.x","buffermaker":"0.0.x"},"readme":"node-kafka-zookeeper\n=======\n\nA high-level client library in Node.js for the Apache Kafka project with Zookeeper integration\n\n[Kafka](http://incubator.apache.org/kafka/index.html) is a persistent, efficient, distributed publish/subscribe messaging system.  \n[Prozess](https://github.com/cainus/Prozess) is a Kafka client library used for low-level access from node-kafka-zookeeper.\n\n###Consumer example:\n\nA `Zookeeper` object handles broker enumeration and offset storage\n```javascript\nvar Zookeeper = require('kafka-zookeeper').Zookeeper;\nvar zk = new Zookeeper({\n  host: 'kafka00.lan',\n  port: 2181\n});\n\nvar onMessages = function(messages, error, cb) {\n  if (error) return console.error(error);\n  console.log('Received %d messages', messages.length);\n\n  // true  - (Acknowledge) Update Zk offsets and continue consuming\n  // false - (Fail) Resend the same batch in 5 seconds so I don't\n  //                have to put it somewhere. TODO: configure wait\n  cb(true);\n}\n\n// Start consuming\n// TODO: Support message filter function argument\nzk.consumeTopic('MessageHeaders', 'dcrouse', onMessages);\n\n// Stop consuming\n// TODO: Implement\n\n```\n\n###Utility examples:\n\nThe `Zookeeper` object also exposes some utility functions - used internally and useful for testing\n```javascript\nvar _ = require('underscore');\nvar Zookeeper = require('../lib/Zookeeper');\n\nvar zk = new Zookeeper({\n  host: 'localhost',\n  port: 2181\n});\n\nvar topic = 'KafkaTopic', group = 'ConsumerGroup';\n\n// Retrieve all consumer offsets for topic/group\nvar onConsumerOffsets = function(offsets, error) {\n  if (error) return console.error('onConsumerOffsets', error);\n  console.log('Offsets', offsets);\n};\n\nzk.getConsumerOffsets(topic, group, onConsumerOffsets);\n\n// Initialize consumer offsets\nvar onInitializeConsumerOffsets = function(error) {\n  if (error) return console.error('onInitializeConsumerOffsets', error);\n  console.log('Consumer offsets initialized');\n};\n\nzk.initializeConsumerOffsets(topic, group, onInitializeConsumerOffsets);\n```\n\n###Installation:\n\n  npm install kafka-zookeeper\n\n###Checkout the code and run the tests:\n\n  git clone https://github.com/devoncrouse/node-kafka-zookeeper.git  \n  cd node-kafka-zookeeper; npm test\n\n###Kafka Compatability matrix:\n\n<table>\n  <tr>\n     <td>Kakfa 0.8.0 Release</td><td>Not Supported</td>\n  </tr>\n  <tr>\n    <td>Kafka 0.7.2 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.1 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.0 Release</td><td>Supported</td>\n  <tr>\n    <td>kafka-0.6</td><td>Consumer-only support.</td>\n  <tr>\n    <td>kafka-0.05</td><td>Not Supported</td>\n</table>\n\nVersions taken from http://incubator.apache.org/kafka/downloads.html\n","_id":"kafka-zookeeper@0.0.11","dist":{"shasum":"21ac0de37bcb716d0d167ddb43f0b7403c4d50d6","tarball":"https://registry.npmjs.org/kafka-zookeeper/-/kafka-zookeeper-0.0.11.tgz","integrity":"sha512-a1c3nqyV6xD91N2ErCXNDKmDFR36mZ4QGZ4bph7C2Hs2AH4VFJqhDz2WYsJTtbefsd5lA/PEf4/XFWm0Kgw23A==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIBq5qhG1BmqJo4K0YFX56d2mys6c1dA4jKV3GAN2OjJzAiBbml4l4MIwdqDroq5pvbE/T1TPA+J0fYqcpsWsCbVEYg=="}]},"_npmVersion":"1.1.63","_npmUser":{"name":"devoncrouse","email":"devoncrouse@gmail.com"}},"0.0.12":{"name":"kafka-zookeeper","description":"A high-level client library in Node.js for the Apache Kafka project with Zookeeper integration","keywords":["kafka","producer","consumer","zookeeper","apache"],"version":"0.0.12","bugs":{"url":"https://github.com/devoncrouse/node-kafka-zookeeper/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"devoncrouse","email":"devoncrouse@gmail.com"}],"contributors":[],"engines":{"node":">=0.8"},"dependencies":{"prozess":"0.6.x","zookeeper":"3.4.x","optimist":"0.6.x","winston":"0.7.x","underscore":"1.5.x","underscore.string":"2.3.x","bignum":"0.6.x","async":"0.2.x"},"devDependencies":{"jscoverage":"0.3.x","coveralls":"1.1.x","mockery":"1.4.x","hottap":"1.0.x","mocha":"1.3.x","should":"1.1.x","sinon":"1.5.x","buffermaker":"0.0.x"},"readme":"node-kafka-zookeeper\n=======\n\nA high-level client library in Node.js for the Apache Kafka project with Zookeeper integration\n\n[Kafka](http://incubator.apache.org/kafka/index.html) is a persistent, efficient, distributed publish/subscribe messaging system.  \n[Prozess](https://github.com/cainus/Prozess) is a Kafka client library used for low-level access from node-kafka-zookeeper.\n\n###Consumer example:\n\nA `Zookeeper` object handles broker enumeration and offset storage\n```javascript\nvar Zookeeper = require('kafka-zookeeper').Zookeeper;\nvar zk = new Zookeeper({\n  host: 'kafka00.lan',\n  port: 2181\n});\n\nvar onMessages = function(messages, error, cb) {\n  if (error) return console.error(error);\n  console.log('Received %d messages', messages.length);\n\n  // true  - (Acknowledge) Update Zk offsets and continue consuming\n  // false - (Fail) Resend the same batch in 5 seconds so I don't\n  //                have to put it somewhere. TODO: configure wait\n  cb(true);\n}\n\n// Start consuming\n// TODO: Support message filter function argument\nzk.consumeTopic('MessageHeaders', 'dcrouse', onMessages);\n\n// Stop consuming\n// TODO: Implement\n\n```\n\n###Utility examples:\n\nThe `Zookeeper` object also exposes some utility functions - used internally and useful for testing\n```javascript\nvar _ = require('underscore');\nvar Zookeeper = require('../lib/Zookeeper');\n\nvar zk = new Zookeeper({\n  host: 'localhost',\n  port: 2181\n});\n\nvar topic = 'KafkaTopic', group = 'ConsumerGroup';\n\n// Retrieve all consumer offsets for topic/group\nvar onConsumerOffsets = function(offsets, error) {\n  if (error) return console.error('onConsumerOffsets', error);\n  console.log('Offsets', offsets);\n};\n\nzk.getConsumerOffsets(topic, group, onConsumerOffsets);\n\n// Initialize consumer offsets\nvar onInitializeConsumerOffsets = function(error) {\n  if (error) return console.error('onInitializeConsumerOffsets', error);\n  console.log('Consumer offsets initialized');\n};\n\nzk.initializeConsumerOffsets(topic, group, onInitializeConsumerOffsets);\n```\n\n###Installation:\n\n  npm install kafka-zookeeper\n\n###Checkout the code and run the tests:\n\n  git clone https://github.com/devoncrouse/node-kafka-zookeeper.git  \n  cd node-kafka-zookeeper; npm test\n\n###Kafka Compatability matrix:\n\n<table>\n  <tr>\n     <td>Kakfa 0.8.0 Release</td><td>Not Supported</td>\n  </tr>\n  <tr>\n    <td>Kafka 0.7.2 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.1 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.0 Release</td><td>Supported</td>\n  <tr>\n    <td>kafka-0.6</td><td>Consumer-only support.</td>\n  <tr>\n    <td>kafka-0.05</td><td>Not Supported</td>\n</table>\n\nVersions taken from http://incubator.apache.org/kafka/downloads.html\n","readmeFilename":"README.md","_id":"kafka-zookeeper@0.0.12","dist":{"shasum":"059a10cac2b028916fc5da408581fa13fef76f0e","tarball":"https://registry.npmjs.org/kafka-zookeeper/-/kafka-zookeeper-0.0.12.tgz","integrity":"sha512-oteUK4E6Nejn1y5grhm0IHy2FZjbtYQNFHDiFe9e09cnBBh1kYAzCA4gdDDi0tDn0FMthQhFrXob0vahrO9dhQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIG08aI8LZk+iOzXV+FYlkYTYjL60GjrEWuMHL6Ci3dIXAiEA1X6S0zKJWDDIO93XwBBqMhnNLn76U4/dKY7VbtHHXrU="}]},"_from":".","_npmVersion":"1.2.30","_npmUser":{"name":"devoncrouse","email":"devoncrouse@gmail.com"}},"0.0.13":{"name":"kafka-zookeeper","description":"A high-level client library in Node.js for the Apache Kafka project with Zookeeper integration","keywords":["kafka","producer","consumer","zookeeper","apache"],"version":"0.0.13","repository":{"type":"git","url":"https://github.com/devoncrouse/node-kafka-zookeeper.git"},"bugs":{"url":"https://github.com/devoncrouse/node-kafka-zookeeper/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"devoncrouse","email":"devoncrouse@gmail.com"}],"contributors":[{"name":"Hans Donner"}],"engines":{"node":">=0.10.18"},"dependencies":{"prozess":"0.6.x","zookeeper":"3.4.x","optimist":"0.6.x","underscore":"1.5.x","underscore.string":"2.3.x","bignum":"0.6.x","async":"0.2.x"},"devDependencies":{"winston":"0.7.x","jscoverage":"0.3.x","coveralls":"1.1.x","mockery":"1.4.x","hottap":"1.0.x","mocha":"1.3.x","should":"1.1.x","sinon":"1.5.x","buffermaker":"0.0.x"},"readme":"node-kafka-zookeeper\n=======\n\nA high-level client library in Node.js for the Apache Kafka project with Zookeeper integration\n\n[Kafka](http://incubator.apache.org/kafka/index.html) is a persistent, efficient, distributed publish/subscribe messaging system.  \n[Prozess](https://github.com/cainus/Prozess) is a Kafka client library used for low-level access from node-kafka-zookeeper.\n\n###Consumer example:\n\nA `Kafkazoo` object handles broker enumeration and offset storage\n```javascript\nvar Kafkazoo = require('kafka-zookeeper').Kafkazoo;\nvar kafka = new Kafkazoo({\n  host: 'localhost',\n  port: 2181,\n  zkPath: '/'\n});\n\nvar onMessages = function (error, messages, acknowledge) {\n    if (error) return log.error(error);\n    // log some details\n    log.info('Received %d messages', messages.length);\n    log.debug(messages[0].substring(0, 100) + '...');\n\n    // and get next batch\n    acknowledge(true); // false will resend the same messages after a delay\n};\n\n// Start consuming\nkafka.consume('MessageHeaders', 'dcrouse', onMessages);\n\n// Stop consuming\n\n```\n\n###Utility examples:\n\nThe `Kafkazoo` object also exposes some utility functions - used internally and useful for testing\n```javascript\nvar _ = require('underscore');\nvar Kafkazoo = require('kafka-zookeeper');\n\nvar kafka = new Kafkazoo({\n  host: 'localhost',\n  port: 2181\n});\n\nvar topic = 'KafkaTopic', group = 'ConsumerGroup';\n\n// Retrieve all consumer offsets for topic/group\nvar onConsumerOffsets = function(offsets, error) {\n  if (error) return console.error('onConsumerOffsets', error);\n  console.log('Offsets', offsets);\n};\n\nkafka.getConsumerOffsets(topic, group, onConsumerOffsets);\n\n// Initialize consumer offsets\nvar onInitializeConsumerOffsets = function(error) {\n  if (error) return console.error('onInitializeConsumerOffsets', error);\n  console.log('Consumer offsets initialized');\n};\n\nkafka.initializeConsumerOffsets(topic, group, onInitializeConsumerOffsets);\n```\n\n###Installation:\n\n  npm install kafka-zookeeper\n\n###Checkout the code and run the tests:\n\n  git clone https://github.com/devoncrouse/node-kafka-zookeeper.git  \n  cd node-kafka-zookeeper; npm test\n\n###Kafka Compatability matrix:\n\n<table>\n  <tr>\n     <td>Kakfa 0.8.0 Release</td><td>Not Supported</td>\n  </tr>\n  <tr>\n    <td>Kafka 0.7.2 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.1 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.0 Release</td><td>Supported</td>\n  <tr>\n    <td>kafka-0.6</td><td>Consumer-only support.</td>\n  <tr>\n    <td>kafka-0.05</td><td>Not Supported</td>\n</table>\n\nVersions taken from http://incubator.apache.org/kafka/downloads.html\n","readmeFilename":"README.md","_id":"kafka-zookeeper@0.0.13","dist":{"shasum":"01c55cdf8bec1d3f2cc83c1fe7c692704064139c","tarball":"https://registry.npmjs.org/kafka-zookeeper/-/kafka-zookeeper-0.0.13.tgz","integrity":"sha512-m4vHwc0qYs357g+i/tgej1fab4EX/TdI0He/76EimUZlXNaeL4zQevwiOHhlTxcJnEdbcH6xUJf6KbQQsaXSyg==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIAOBDfvf01eH19qvArZod2R2dYYObjoXv2VQOaBB+DSaAiEAn5C2m0gUtayOoC2eOe1TE1y6BDYUGKXSqsqmbUqGuHc="}]},"_from":".","_npmVersion":"1.3.8","_npmUser":{"name":"devoncrouse","email":"devoncrouse@gmail.com"}},"0.0.14":{"name":"kafka-zookeeper","description":"A high-level client library in Node.js for the Apache Kafka project with Zookeeper integration","keywords":["kafka","producer","consumer","zookeeper","apache"],"version":"0.0.14","repository":{"type":"git","url":"https://github.com/devoncrouse/node-kafka-zookeeper.git"},"bugs":{"url":"https://github.com/devoncrouse/node-kafka-zookeeper/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"devoncrouse","email":"devoncrouse@gmail.com"}],"contributors":[{"name":"Hans Donner"}],"engines":{"node":">=0.10.18"},"dependencies":{"prozess":"0.6.x","zookeeper":"3.4.x","optimist":"0.6.x","underscore":"1.5.x","underscore.string":"2.3.x","bignum":"0.6.x","async":"0.2.x"},"devDependencies":{"winston":"0.7.x","jscoverage":"0.3.x","coveralls":"1.1.x","mockery":"1.4.x","hottap":"1.0.x","mocha":"1.3.x","should":"1.1.x","sinon":"1.5.x","buffermaker":"0.0.x"},"readme":"node-kafka-zookeeper\n=======\n\nA high-level client library in Node.js for the Apache Kafka project with Zookeeper integration\n\n[Kafka](http://incubator.apache.org/kafka/index.html) is a persistent, efficient, distributed publish/subscribe messaging system.  \n[Prozess](https://github.com/cainus/Prozess) is a Kafka client library used for low-level access from node-kafka-zookeeper.\n\n###Consumer example:\n\nA `Kafkazoo` object handles broker enumeration and offset storage\n```javascript\nvar Kafkazoo = require('kafka-zookeeper').Kafkazoo;\nvar kafka = new Kafkazoo({\n  host: 'localhost',\n  port: 2181,\n  zkPath: '/'\n});\n\nvar onMessages = function (error, messages, acknowledge) {\n    if (error) return log.error(error);\n    // log some details\n    log.info('Received %d messages', messages.length);\n    log.debug(messages[0].substring(0, 100) + '...');\n\n    // and get next batch\n    acknowledge(true); // false will resend the same messages after a delay\n};\n\n// Start consuming\nkafka.consume('MessageHeaders', 'dcrouse', onMessages);\n\n// Stop consuming\n\n```\n\n###Utility examples:\n\nThe `Kafkazoo` object also exposes some utility functions - used internally and useful for testing\n```javascript\nvar _ = require('underscore');\nvar Kafkazoo = require('kafka-zookeeper');\n\nvar kafka = new Kafkazoo({\n  host: 'localhost',\n  port: 2181\n});\n\nvar topic = 'KafkaTopic', group = 'ConsumerGroup';\n\n// Retrieve all consumer offsets for topic/group\nvar onConsumerOffsets = function(offsets, error) {\n  if (error) return console.error('onConsumerOffsets', error);\n  console.log('Offsets', offsets);\n};\n\nkafka.getConsumerOffsets(topic, group, onConsumerOffsets);\n\n// Initialize consumer offsets\nvar onInitializeConsumerOffsets = function(error) {\n  if (error) return console.error('onInitializeConsumerOffsets', error);\n  console.log('Consumer offsets initialized');\n};\n\nkafka.initializeConsumerOffsets(topic, group, onInitializeConsumerOffsets);\n```\n\n###Installation:\n\n  npm install kafka-zookeeper\n\n###Checkout the code and run the tests:\n\n  git clone https://github.com/devoncrouse/node-kafka-zookeeper.git  \n  cd node-kafka-zookeeper; npm test\n\n###Kafka Compatability matrix:\n\n<table>\n  <tr>\n     <td>Kakfa 0.8.0 Release</td><td>Not Supported</td>\n  </tr>\n  <tr>\n    <td>Kafka 0.7.2 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.1 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.0 Release</td><td>Supported</td>\n  <tr>\n    <td>kafka-0.6</td><td>Consumer-only support.</td>\n  <tr>\n    <td>kafka-0.05</td><td>Not Supported</td>\n</table>\n\nVersions taken from http://incubator.apache.org/kafka/downloads.html\n","readmeFilename":"README.md","_id":"kafka-zookeeper@0.0.14","dist":{"shasum":"496b4b36bfd87f84dee10291cad8a77585532b6e","tarball":"https://registry.npmjs.org/kafka-zookeeper/-/kafka-zookeeper-0.0.14.tgz","integrity":"sha512-s0NVdw8RSM33gI5Ah6fnhhAZ6CRPQ0iT4ZtnVeGUkyFN3aP0l59jkTpKiGqS1eZwkGlQh6Eib58wImRCoxyDKQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDiYt+Ikq2SNbCwSZVDX2MHhSWoL5Hlv8oQgyiKG2MlpQIhALKXvLQaOxB9l8zzfwnK13CF19jZza/LW09bjh5pYBrb"}]},"_from":".","_npmVersion":"1.3.8","_npmUser":{"name":"devoncrouse","email":"devoncrouse@gmail.com"}},"0.0.15":{"name":"kafka-zookeeper","description":"A high-level client library in Node.js for the Apache Kafka project with Zookeeper integration","keywords":["kafka","producer","consumer","zookeeper","apache"],"version":"0.0.15","repository":{"type":"git","url":"https://github.com/devoncrouse/node-kafka-zookeeper.git"},"bugs":{"url":"https://github.com/devoncrouse/node-kafka-zookeeper/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"devoncrouse","email":"devoncrouse@gmail.com"}],"contributors":[{"name":"Hans Donner"}],"engines":{"node":">=0.10.18"},"dependencies":{"prozess":"0.6.x","zookeeper":"3.4.x","optimist":"0.6.x","underscore":"1.5.x","underscore.string":"2.3.x","bignum":"0.6.x","async":"0.2.x"},"devDependencies":{"winston":"0.7.x","jscoverage":"0.3.x","coveralls":"1.1.x","mockery":"1.4.x","hottap":"1.0.x","mocha":"1.3.x","should":"1.1.x","sinon":"1.5.x","buffermaker":"0.0.x"},"readme":"node-kafka-zookeeper\n=======\n\nA high-level client library in Node.js for the Apache Kafka project with Zookeeper integration\n\n[Kafka](http://incubator.apache.org/kafka/index.html) is a persistent, efficient, distributed publish/subscribe messaging system.  \n[Prozess](https://github.com/cainus/Prozess) is a Kafka client library used for low-level access from node-kafka-zookeeper.\n\n###Consumer example:\n\nA `Kafkazoo` object handles broker enumeration and offset storage\n```javascript\nvar Kafkazoo = require('kafka-zookeeper').Kafkazoo;\nvar kafka = new Kafkazoo({\n  host: 'localhost',\n  port: 2181,\n  zkPath: '/'\n});\n\nvar onMessages = function (error, messages, acknowledge) {\n    if (error) return log.error(error);\n    // log some details\n    log.info('Received %d messages', messages.length);\n    log.debug(messages[0].substring(0, 100) + '...');\n\n    // and get next batch\n    acknowledge(true); // false will resend the same messages after a delay\n};\n\n// Start consuming\nkafka.consume('MessageHeaders', 'dcrouse', onMessages);\n\n// Stop consuming\n\n```\n\n###Utility examples:\n\nThe `Kafkazoo` object also exposes some utility functions - used internally and useful for testing\n```javascript\nvar _ = require('underscore');\nvar Kafkazoo = require('kafka-zookeeper');\n\nvar kafka = new Kafkazoo({\n  host: 'localhost',\n  port: 2181\n});\n\nvar topic = 'KafkaTopic', group = 'ConsumerGroup';\n\n// Retrieve all consumer offsets for topic/group\nvar onConsumerOffsets = function(offsets, error) {\n  if (error) return console.error('onConsumerOffsets', error);\n  console.log('Offsets', offsets);\n};\n\nkafka.getConsumerOffsets(topic, group, onConsumerOffsets);\n\n// Initialize consumer offsets\nvar onInitializeConsumerOffsets = function(error) {\n  if (error) return console.error('onInitializeConsumerOffsets', error);\n  console.log('Consumer offsets initialized');\n};\n\nkafka.initializeConsumerOffsets(topic, group, onInitializeConsumerOffsets);\n```\n\n###Installation:\n\n  npm install kafka-zookeeper\n\n###Checkout the code and run the tests:\n\n  git clone https://github.com/devoncrouse/node-kafka-zookeeper.git  \n  cd node-kafka-zookeeper; npm test\n\n###Kafka Compatability matrix:\n\n<table>\n  <tr>\n     <td>Kakfa 0.8.0 Release</td><td>Not Supported</td>\n  </tr>\n  <tr>\n    <td>Kafka 0.7.2 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.1 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.0 Release</td><td>Supported</td>\n  <tr>\n    <td>kafka-0.6</td><td>Consumer-only support.</td>\n  <tr>\n    <td>kafka-0.05</td><td>Not Supported</td>\n</table>\n\nVersions taken from http://incubator.apache.org/kafka/downloads.html\n","readmeFilename":"README.md","_id":"kafka-zookeeper@0.0.15","dist":{"shasum":"422464d2c1edbd00cd3973f68517c02c483fb4b4","tarball":"https://registry.npmjs.org/kafka-zookeeper/-/kafka-zookeeper-0.0.15.tgz","integrity":"sha512-qspjND8E2CbacmV+rGl5V48KXD2g1qevKPQN9SV4HVy76KvbTrB8PVpXs6nJ133S2hnRSrHGTVP2r4ENWhXjog==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIGWz2kcOVeHIefI3HPb0RTiIqCofWtT7ZbqYsgiyDeOQAiEA5Qb1T1GCv137LECTNFc7crMLpH7oIJLUu6hDhMSoAGs="}]},"_from":".","_npmVersion":"1.3.8","_npmUser":{"name":"devoncrouse","email":"devoncrouse@gmail.com"}}},"readme":"node-kafka-zookeeper\n=======\n\nA high-level client library in Node.js for the Apache Kafka project with Zookeeper integration\n\n[Kafka](http://incubator.apache.org/kafka/index.html) is a persistent, efficient, distributed publish/subscribe messaging system.  \n[Prozess](https://github.com/cainus/Prozess) is a Kafka client library used for low-level access from node-kafka-zookeeper.\n\n##Consumer example:\n\nA `Zookeeper` object handles broker enumeration and offset storage\n```javascript\nvar Zookeeper = require('kafka-zookeeper').Zookeeper;\nvar zk = new Zookeeper({\n  host: 'kafka00.lan',\n  port: 2181\n});\n\nvar onMessages = function(messages, error, cb) {\n  if (error) return console.error(error);\n  console.log('Received %d messages', messages.length);\n\n  // true  - (Acknowledge) Update Zk offsets and continue consuming\n  // false - (Fail) Resend the same batch in 5 seconds so I don't\n  //                have to put it somewhere. TODO: configure wait\n  cb(true);\n}\n\n// Start consuming\n// TODO: Support message filter function argument\nzk.consumeTopic('MessageHeaders', 'dcrouse', onMessages);\n\n// Stop consuming\n// TODO: Implement\n\n```\n\n##Installation:\n\n  npm install kafka-zookeeper\n\n##Checkout the code and run the tests:\n\n  git clone https://github.com/devoncrouse/node-kafka-zookeeper.git  \n  cd node-kafka-zookeeper; make test-cov && open coverage.html\n\n##Kafka Compatability matrix:\n\n<table>\n  <tr>\n     <td>Kakfa 0.8.0 Release</td><td>Not Supported</td>\n  </tr>\n  <tr>\n    <td>Kafka 0.7.2 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.1 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.0 Release</td><td>Supported</td>\n  <tr>\n    <td>kafka-0.6</td><td>Consumer-only support.</td>\n  <tr>\n    <td>kafka-0.05</td><td>Not Supported</td>\n</table>\n\nVersions taken from http://incubator.apache.org/kafka/downloads.html\n","maintainers":[{"name":"devoncrouse","email":"devoncrouse@gmail.com"}],"time":{"modified":"2022-06-19T07:43:39.581Z","created":"2013-07-17T19:11:09.628Z","0.0.1":"2013-07-17T19:11:10.240Z","0.0.2":"2013-07-18T03:13:18.155Z","0.0.3":"2013-07-18T06:01:46.997Z","0.0.4":"2013-07-18T16:46:11.828Z","0.0.5":"2013-07-18T16:56:00.843Z","0.0.6":"2013-07-18T22:44:53.978Z","0.0.7":"2013-07-23T00:14:13.175Z","0.0.8":"2013-07-23T05:58:02.541Z","0.0.9":"2013-07-23T19:38:10.062Z","0.0.10":"2013-07-23T22:50:47.106Z","0.0.11":"2013-07-23T23:08:58.552Z","0.0.12":"2013-08-21T23:11:27.292Z","0.0.13":"2013-09-11T16:35:04.608Z","0.0.14":"2013-09-16T03:38:00.228Z","0.0.15":"2013-09-20T23:39:57.055Z"},"repository":{"type":"git","url":"https://github.com/devoncrouse/node-kafka-zookeeper.git"}}