diff --git a/service/ebroker.js b/service/ebroker.js index edc2482..fea41b1 100644 --- a/service/ebroker.js +++ b/service/ebroker.js @@ -13,7 +13,7 @@ var ebroker = { // console.log('THIS-> req.body -> ', req.body); const kafka_topic ="NEW_OFFER_"+ message.assign_mode; const kafkaConfig = new KafkaConfig(); - const messages = [{ key: "offer", value: message.stringify() }]; + const messages = [{ key: "offer", value: JSON.stringify(message) }]; kafkaConfig.produce(kafka_topic, messages).then(r =>{ console.log('THIS->RET-> ',r); } );