From beb01b45eb4e3ac7fb3ba274d136de2e40bdea7f Mon Sep 17 00:00:00 2001 From: Mingmin Chen Date: Thu, 28 Jun 2018 16:08:32 -0700 Subject: [PATCH] revert stringify --- lib/kafka_data_producer.js | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/lib/kafka_data_producer.js b/lib/kafka_data_producer.js index c55461c..e41566d 100644 --- a/lib/kafka_data_producer.js +++ b/lib/kafka_data_producer.js @@ -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) {