kafka-node - npm Package Compare versions

Comparing version 0.2.9 to 0.2.10

lib/highLevelProducer.js

		@@ -54,2 +54,3 @@ 'use strict';
		this.client.on('error', function (err) {
		self.emit('error', err);
		});
		@@ -123,2 +124,6 @@ this.client.on('close', function () {

		HighLevelProducer.prototype.close = function (cb) {
		this.client.close(cb);
		}

		function noAcks() {
		@@ -125,0 +130,0 @@ return 'Not require ACK';

lib/producer.js

		@@ -54,2 +54,3 @@ 'use strict';
		this.client.on('error', function (err) {
		self.emit('error', err);
		});
		@@ -117,2 +118,6 @@ this.client.on('close', function () {

		Producer.prototype.close = function (cb) {
		this.client.close(cb);
		}

		function noAcks() {
		@@ -119,0 +124,0 @@ return 'Not require ACK';

package.json

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

test/test.producer.js

		@@ -69,3 +69,9 @@ 'use strict';
		});
		});
		});

		describe('#close', function () {
		it('should close successfully', function (done) {
		producer.close(done);
		});
		});
		});

New alerts