My Java application consuming a change stream of collection. There’s no problem. But now I need to implement scaling of consuming a change stream, meaning I have 5 pods of the same application consuming the stream. I use distributed locking to syncronize on consuming of change stream. But I notice that it does not send events parallely to all listeners/consumers. Do I miss anything or there’s no way to send change event to all subscribers at the same time out of the box. I do understand that it’s possible to scale using a queue and them reading from it.
Skip to main content
New & Unread Topics
Topic | Replies | Views | Activity |
---|---|---|---|
How to Efficiently Rename a Field Across 1 Million MongoDB Documents? | 1 | 679 | Jul 2024 |
Sorting behavior and sorting sequence for mongodb | 3 | 468 | Jun 2024 |
Darshan Hiranandani : Has anyone tried disabling writeConcern acknowledgment to enhance performance? | 1 | 63 | Aug 2024 |
Need optimization advice for querying 2 million IP ranges at high throughput (100s/sec) | 1 | 65 | Nov 2024 |
Performance issues with change streams and multiple collections on single cluster | 0 | 31 | Feb 13 |