search

debezium / debezium-design-documents

Apache License 2.0
29 stars 10 forks source link

DBZ-7234 DDD-8 Add MongoDB #11

Closed mfvitale closed 2 months ago

mfvitale commented 3 months ago
  1. First simply compare the resume token of current streaming iteration with the lower bound resume token. If it matches, we have reached the lower bound.

This will not work if the event with the exact resume token is filtered. I prefer to just compere if the event has a greater timestamp.

jcechace commented 3 months ago
  1. First simply compare the resume token of current streaming iteration with the lower bound resume token. If it matches, we have reached the lower bound.

This will not work if the event with the exact resume token is filtered. I prefer to just compere if the event has a greater timestamp.

As discussed on Zulip -- this is not true as filtering for MongoDb is done on the DB side. Nevertheless, comparing the timestamps is sufficient as the original proposed comparison is logically equal to just comparing timestamps.

Otherwise LGTM, thanks for putting this together!

mfvitale commented 3 months ago

@jpechane Can you please have a look?