This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch feat/bench-vsr-visualization
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 22d48df6e Merge branch 'master' into feat/bench-vsr-visualization
add 6513b2f55 fix(connectors): fix postgres source CDC producing no
messages (#3640)
add 12a7b7046 Merge branch 'master' into feat/bench-vsr-visualization
No new revisions were added by this update.
Summary of changes:
.gitignore | 2 +
core/connectors/sources/postgres_source/README.md | 31 +-
.../sources/postgres_source/src/cdc_fixtures.rs | 89 ++
core/connectors/sources/postgres_source/src/lib.rs | 1100 ++++++++++++++++----
core/integration/tests/connectors/fixtures/mod.rs | 5 +-
.../tests/connectors/fixtures/postgres/cdc.rs | 206 ++++
.../connectors/fixtures/postgres/container.rs | 21 +-
.../tests/connectors/fixtures/postgres/mod.rs | 2 +
.../postgres/cdc_restart_connectors}/config.toml | 0
core/integration/tests/connectors/postgres/mod.rs | 1 +
.../connectors/postgres/postgres_source_cdc.rs | 584 +++++++++++
.../source_cdc_restart.toml} | 17 +-
12 files changed, 1825 insertions(+), 233 deletions(-)
create mode 100644 core/connectors/sources/postgres_source/src/cdc_fixtures.rs
create mode 100644 core/integration/tests/connectors/fixtures/postgres/cdc.rs
copy core/{connectors/sources/postgres_source =>
integration/tests/connectors/postgres/cdc_restart_connectors}/config.toml (100%)
create mode 100644
core/integration/tests/connectors/postgres/postgres_source_cdc.rs
copy core/integration/tests/connectors/{api/config.toml =>
postgres/source_cdc_restart.toml} (61%)
