Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

use ts_ms to determine the lag between the source database update and Debezium #13440

Closed
lmatz opened this issue Nov 15, 2023 · 0 comments · Fixed by #13877
Closed

use ts_ms to determine the lag between the source database update and Debezium #13440

lmatz opened this issue Nov 15, 2023 · 0 comments · Fixed by #13877
Assignees
Milestone

Comments

@lmatz
Copy link
Contributor

lmatz commented Nov 15, 2023

Is your feature request related to a problem? Please describe.

Currently it is awkward to determine the lag between the source database update and Debezium.

Describe the solution you'd like

Suggested by @StrikeW

In the source object, ts_ms indicates the time that the change was made in the database. By comparing the value for payload.source.ts_ms with the value for payload.ts_ms, you can determine the lag between the source database update and Debezium.

Describe alternatives you've considered

No response

Additional context

Required by CDC testing and it also allows the user to monitor the lag between upstream DB and RW. https://github.com/risingwavelabs/risingwave-docs/issues/1513
cc: @cyliu0

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging a pull request may close this issue.

3 participants