From 84a839a0c54ca248f7355f4a3735b616ee30d9bd Mon Sep 17 00:00:00 2001 From: Hannah Fouasnon Date: Thu, 22 Mar 2012 21:03:54 -0700 Subject: [PATCH] Send exactly the same message to kafka that's used in the hash function. (Fixes #2) --- lib/Client.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/Client.js b/lib/Client.js index 6268eea..ef60b04 100644 --- a/lib/Client.js +++ b/lib/Client.js @@ -229,7 +229,7 @@ module.exports = std.Class(Connection, function(supr) { } this._encodeMessage = function(message) { - return std.pack('CN', MAGIC_VALUE, std.crc32(message)) + message + return std.pack('CN', MAGIC_VALUE, std.crc32(message)) + std.utf8_encode(message) } this._onData = function(buf) {