How to achieve Producer to Consumer(s) pattern? (Kafka like)

[sorooshme]

Hey, We are planning on using BullMQ for our notification system.

Consider the following example:

await notificationQueue.add('new-notification', notificationData);

new Worker('email-notification', emailProcessor);
new Worker('whatsapp-notification', whatsappProcessor);
new Worker('push-notification', pushProcessor);
// And many more...

How to achieve this? adding an event and processing it in multiple workers? something like Kafka consumer groups

[manast]

This maybe? https://docs.bullmq.io/bullmq-pro/groups

[sorooshme]

Yes, that addresses my question, Thank you.