When Send Chinese message, lost some characters...
kafkaesque.produce({topic: 'testing', partition: 0},
'测aaa',
function(err, response) {
if (err) {
console.log(err);
} else {
}
console.log(response);
});
Run kafka consumer on cosole
flying@Server:~/kafka$ bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic testing
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
测a
It should be "测aaa", but only received "测a"!
When Send Chinese message, lost some characters...
Run kafka consumer on cosole
It should be "测aaa", but only received "测a"!