diff --git a/src/app.js b/src/app.js index 2d8ec96..6738344 100644 --- a/src/app.js +++ b/src/app.js @@ -119,6 +119,7 @@ function startKafkaConsumer(handlers) { projectId: messageJSON.projectId, topicId, postId, + authorHandle: notification.contents.userHandle, }, recipients, replyTo,