-
Notifications
You must be signed in to change notification settings - Fork 1.9k
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
[Feature][Connector-V2][Postgres-cdc]Support for Postgres cdc #5986
Conversation
Very nice need this feature. |
@hailin0 @ic4y @EricJoy2048 @Hisoka-X @TyrantLucifer Please help review, thank you |
We have found some serious bugs in PG CDC during testing. Please wait for us to fix them before reviewing this PR. |
waiting for ci passed |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
please add new connector into seatunnel-dist/pom.xml
please add new connector into seatunnel-dist/pom.xml
I found that there is currently no CDC that supports PG partition tables. For example, I created a people table, Then create 3 more partitions --Publicpeople_ Y2000 definition CREATE TABLE public.people_y2000 PARTITION OF public.people FOR VALUES FROM ('2000-01-01') TO ('2001-01-01'); --Publicpeople_ Y2000 foreign keys --Publicpeople_ Y2001 definition CREATE TABLE public.people_y2001 PARTITION OF public.people FOR VALUES FROM ('2001-01-01') TO ('2002-01-01'); --Publicpeople_ Y2001 foreign keys --Publicpeople_ Y2002 definition CREATE TABLE public.people_y2002 PARTITION OF public.people FOR VALUES FROM ('2002-01-01') TO ('2003-01-01'); --Publicpeople_ Y2002 foreign keys |
Purpose of this pull request
Support for Postgres cdc
Does this PR introduce any user-facing change?
How was this patch tested?
new e2e test
Check list
New License Guide
release-note
.