Async Notification is not processed

[karthik-tarento]

Hello,

We are using sunbird-notification-service - release-4.4.0 version
Our certificate generator flink job is generating a request to send email when the user completes the course. The same is received in the sunbird-notification-service (via learner service) and initiating the send email functionality.
This send email is not sync -- so, sunbird-notification-service writes the event into "dev.lms.notification" kafka topic.
But we are not able to identify which service is consuming the messages from this topic.
Please provide the details for the same.

Regards,
Karthik

[rhwarrier]

@reshmi-nair can you please take a look ?

[reshmi-nair]

@karthik-tarento LMS jobs repo has a samza job which reads this kafka messages and sends the notification.

https://github.com/project-sunbird/sunbird-lms-jobs/

[karthik-tarento]

@reshmi-nair - thanks for the info.. will take a look at this code.

[karthik-tarento]

@reshmi-nair - is this lms job re-written as Flink job ? if so, please share the flink job repo link.

[prasadmoka]

@karthik-tarento please find the below link for the notification flink job:
https://github.com/Sunbird-Lern/data-pipeline/tree/release-5.0.0/notification/notification-job

[juhiagl8]

@reshmi-nair when we fire a notification kafka topic with the name of the vm template, will the notification flink job utilise this notification sdk and convert the data wrt to the vm template?

[reshmi-nair]

@juhiagl8 Notification job sends the notification with the content that is received. It does not resolve the template or values in the content. So you need to sent the actual content instead of template name.