		@@ -139,5 +139,5 @@ 'use strict';
		.word8bu('attributes')
		.word32bs('key')
		.word32bu('key')
		.tap(function (vars) {
		if (vars.key == -1) return;
		if (vars.key == 0) return;
		cur += vars.key;
		@@ -148,3 +148,2 @@ this.buffer('key', vars.key);
		.tap(function (vars) {
		if (vars.value == -1) return;
		cur += vars.value;
		@@ -351,3 +350,3 @@ this.buffer('value', vars.value);
		.string(message.key)
		.UInt32BE(message.value.length)
		.UInt32BE(Buffer.byteLength(message.value))
		.string(message.value).make();
		@@ -354,0 +353,0 @@ var crc = crc32.unsigned(m);

package.json

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

test/test.consumer.js

		@@ -172,3 +172,3 @@ 'use strict';
		fetchMinBytes: 1,
		fetchMaxBytes: 1024 * 10,
		fetchMaxBytes: 1024 * 1024,
		fromOffset: false
		@@ -184,3 +184,3 @@ };
		topic.metadata.should.equal('m');
		topic.maxBytes.should.equal(1024 * 10);
		topic.maxBytes.should.equal(1024 * 1024);
		});
		@@ -215,5 +215,5 @@
		topic.metadata.should.equal('m');
		topic.maxBytes.should.equal(1024 * 10);
		topic.maxBytes.should.equal(1024 * 1024);
		});
		});
		});

kafka-node - npm Package Compare versions

New alerts