kafka-node - npm Package Compare versions

Comparing version 0.2.6 to 0.2.7

lib/zookeeper.js

		@@ -210,11 +210,2 @@ 'use strict';
		var brokers = {};
		function getBrokerDetail (id, cb) {
		var path = '/brokers/ids/' + id;
		that.client.getData(path,function (err, data) {
		if (err) return cb(err);
		brokers[id] = JSON.parse(data.toString());
		cb();
		});
		}

		async.each(children, getBrokerDetail, function (err) {
		@@ -236,2 +227,11 @@ if (err) return cb(err);
		}

		function getBrokerDetail (id, cb) {
		var path = '/brokers/ids/' + id;
		that.client.getData(path,function (err, data) {
		if (err) return cb(err);
		brokers[id] = JSON.parse(data.toString());
		cb();
		});
		}
		}
		@@ -238,0 +238,0 @@ );

package.json

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

New alerts