davidzollo opened a new pull request, #11029: URL: https://github.com/apache/seatunnel/pull/11029
## What's changed - add a new `connector-cdc-pg-base` module to centralize the shared PostgreSQL-compatible Debezium property assembly and row deserialization logic - migrate the Postgres CDC source config and incremental source to the shared PG base implementation without changing the existing connector identifier, slot/plugin options, or replica-identity behavior - wire OpenGauss CDC through its own source entry point so it can reuse the PG base behavior while keeping the current OpenGauss plugin identity - add a regression test to keep Postgres table identifier normalization (`schema.table` and `db.schema.table`) backward compatible ## Why - Postgres and OpenGauss currently duplicate the same PG-compatible CDC assembly logic, which makes follow-up maintenance and future connector additions much harder - this change keeps the refactor in a phase-1 shape: common config/deserialization logic moves to the PG base module first, while dialect-specific runtime behavior stays in the existing connector modules to reduce migration risk ## Validation - `./mvnw -f seatunnel-connectors-v2/connector-cdc/pom.xml -pl connector-cdc-pg-base,connector-cdc-postgres,connector-cdc-opengauss -am spotless:apply` - `./mvnw -f seatunnel-connectors-v2/connector-cdc/pom.xml -pl connector-cdc-pg-base,connector-cdc-postgres,connector-cdc-opengauss -am -Dtest=PostgresSourceConfigFactoryTest -DfailIfNoTests=false -Dsurefire.failIfNoSpecifiedTests=false test` - `./mvnw -f seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml -pl connector-cdc-postgres-e2e -am -Dtest=PostgresCDCIT#testDialectCheckDisabledCDCTable -DfailIfNoTests=false -Dsurefire.failIfNoSpecifiedTests=false test` ## Notes - a broader Postgres/OpenGauss CDC e2e matrix was also attempted locally, but it still hits existing environment-level noise outside this refactor path (for example Flink container startup instability in the PR matrix). This PR is intentionally opened as draft so we can keep tightening the wider validation path in parallel. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
