archive-gh-me/node-kafka-rest-client
1
0
Fork 0
mirror of https://github.com/uber-common/node-kafka-rest-client.git synced 2025-12-08 20:59:54 +00:00
Code Issues Projects Releases Wiki Activity

revert stringify

Browse Source
This commit is contained in:
Mingmin Chen 2018-06-28 16:08:32 -07:00
parent d81c6564c2
commit beb01b45eb
1 changed files with 1 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib/kafka_data_producer.js
View File

@ -40,13 +40,7 @@ KafkaDataProducer.prototype.produceSync = function produceSync(topic, produceRec
KafkaDataProducer.prototype.produce = function produce(topic, message, callback) {
var self = this;
var value;
if (typeof message !== 'string' && !Buffer.isBuffer(message)) {
value = JSON.stringify(message);
} else {
value = message;
}
self.producer.produceSync(topic, new ProducerRecord({value: value}), callback);
self.producer.produceSync(topic, new ProducerRecord({value: message}), callback);
};
KafkaDataProducer.prototype.close = function close(callback) {