JSON.stringify(message)

2024-07-09 13:30:38 -04:00
parent 400c82f810
commit 357f0c4608
1 changed files with 1 additions and 1 deletions
@@ -40,7 +40,7 @@ var ebroker = {
            console.log('THIS-> req.body ->  ', req.body);
            console.log('THIS-> req.body message =>  ', message );
            const kafkaConfig = new KafkaConfig();
-            const messages = [{ key: "interest", value: message }];
+            const messages = [{ key: "interest", value: JSON.stringify(message) }];

            kafkaConfig.produce("INTEREST_MSG", messages).then(r =>{
                console.log('THIS->RET->  ',r);