fix json

2024-07-08 11:25:33 -04:00
parent 92ed9e9cd3
commit 6635f2e3ef
1 changed files with 1 additions and 1 deletions
@@ -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);
             } );