Resume CHANGEFEED from last committed cursor timestamp #65573
Labels
A-cdc
Change Data Capture
C-enhancement
Solution expected to add code/behavior + preserve backward-compat (pg compat issues are exception)
O-community
Originated from the community
T-cdc
X-blathers-triaged
blathers was able to find an owner
Is your feature request related to a problem? Please describe.
A CHANGEFEED can fail for multiple reasons internal to CRDB, the Kafka endpoint, etc... After the CHANGEFEED fails, you have to figure out exactly when it failed from the logs and restart from that point after converting to the
cluster_logical_timestamp
epoch format.Describe the solution you'd like
I would like for CRDB to store the last committed timestamp and have some way to simply RESUME from that point. You can easily PAUSE and RESUME jobs, but if the job fails you must resubmit. If the changefeed was created as an object in the database instead of a job, we could do something like:
And it would simple pickup from where it left off.
Epic CRDB-2397
The text was updated successfully, but these errors were encountered: