Aggregation pipeline on restored events from ChangeStream resumeToken

Izzul_Aizad_bin_Azmi · 2024-05-20T06:38:50.963Z

Hi,

We’re currently simulating a crash event where we’ll need to restart the ChangeStream after a few document changes has already happened. The issue is, the new/resumed ChangeStream seems to restore all events including the changes that are supposed to be filtered with the pipeline that we are passing in our collection.watch().

When the service is running normally, the pipeline works and we only receive the filtered events.

Robert_Walters · 2024-05-27T11:36:01.628Z

Wen you define the $source you can specify

     "startAfter": <start-token> | "startAtOperationTime": <timestamp>,

See the complete syntax here.

mongodb.com