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 access nested array | 1 | 554 | Apr 2024 |
Does MongoDB preserve array order in document | 1 | 802 | May 2024 |
Node.js Application and MongoDB in Docker on AWS: Connection Issue without Opening DB Port in Inbound Rules | 0 | 437 | May 2024 |
MongoDB write performance | 2 | 892 | Jun 2024 |
How to flatten nested array. | 1 | 283 | Jul 2024 |