diff --git a/service/ebroker.js b/service/ebroker.js index b3194af..97695ac 100644 --- a/service/ebroker.js +++ b/service/ebroker.js @@ -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);