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) {