-
Notifications
You must be signed in to change notification settings - Fork 599
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
Discussion: the way to maintain direct CDC Backfill with existing direct CDC #13590
Comments
@hzxa21 @fuyufjh @neverchanje PTAL whether the above strategy is ok to you. |
LGTM. Just to make sure we are all on the same page, let me reiterate the plan:
|
Agree with @hzxa21.
For this, after a double thought, I prefer to simply deprecate the old syntax ( For backward compatibility, we shall retain the old code path for a long time, and eventually remove these code in some major version update in the future. |
+1. |
This issue has been open for 60 days with no activity. Could you please update the status? Feel free to continue discussion or close as not planned. |
Here are my thoughts on the way to maintain the CDC backfill feature and the existing direct cdc feature:
The original way of creating a single table cdc by
create table t (…) with ("connector"="xxx-cdc")
(interface 1) is still retained , mainly to support the connector without backfill capability, such ascitus-cdc
and possible new upstreams in the future.For connectors that already support backfill (e.g. mysql-cdc), only tables created with the new syntax
create table t (...) from <source>
(interface 2) will enable backfill. Single table cdc created by the interface 1 won't enable backfill.For connectors that support backfill (e.g. mysql-cdc), we will gradually unify the implementation of interface 1 to the table-on-source implementation, and it is necessary to ensure that the single-table cdc job created by the user previously will still work after the we unified the implementation. (Low priority)
The text was updated successfully, but these errors were encountered: