I just noticed that utf8 isn't supported. I can't tell if this is occurring in the crc32 hashing algorithm or in the packing library. Here's what I've used to verify this behavior:
Producer initialization
var kafka = require('kafka');
var kclient = new kafka.Producer();
Message with utf char that doesn't send
kclient.send('test-raw', 'Guantánamo');
Remove the char and it sends:
kclient.send('test-raw', 'Guantnamo' );
I just noticed that utf8 isn't supported. I can't tell if this is occurring in the crc32 hashing algorithm or in the packing library. Here's what I've used to verify this behavior:
Producer initialization
Message with utf char that doesn't send
Remove the char and it sends: