Skip to content

Commit

Permalink
update log
Browse files Browse the repository at this point in the history
  • Loading branch information
rakeshSgr committed Feb 4, 2022
1 parent 437b166 commit 4a8bdfb
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions config/kafkaConfig.js
Original file line number Diff line number Diff line change
Expand Up @@ -36,10 +36,10 @@ var connect = function() {

consumer.on('message', async function (message) {

console.log("-------Kafka consumner log starts here------------------");
console.log("-------Kafka consumer log starts here------------------");
console.log("Topic Name: ", process.env.SUBMISSION_RATING_QUEUE_TOPIC);
console.log(JSON.stringify(message));
console.log("-------Kafka consumner log ends here------------------");
console.log("-------Kafka consumer log ends here------------------");

submissionRatingQueueConsumer.messageReceived(message)
});
Expand Down

0 comments on commit 4a8bdfb

Please sign in to comment.