You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by eo...@apache.org on 2021/10/13 18:07:33 UTC
[pulsar] branch master updated (52b6512 -> 5c28686)
This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 52b6512 Fix: flaky oracle tests (#12306)
add 5c28686 Added Debezium Source for MS SQL Server (#12256)
No new revisions were added by this update.
Summary of changes:
distribution/io/src/assemble/io.xml | 1 +
pulsar-io/debezium/{oracle => mssql}/pom.xml | 6 +-
.../io/debezium/mssql/DebeziumMsSqlSource.java} | 8 +-
.../resources/META-INF/services/pulsar-io.yaml | 6 +-
.../resources/debezium-mssql-source-config.yaml} | 18 +--
pulsar-io/debezium/pom.xml | 1 +
site2/docs/io-connectors.md | 9 ++
site2/docs/io-debezium-source.md | 66 +++++++++
...bContainer.java => DebeziumMsSqlContainer.java} | 29 ++--
.../debezium/DebeziumMsSqlSourceTester.java | 165 +++++++++++++++++++++
.../debezium/PulsarDebeziumSourcesTest.java | 43 ++++++
11 files changed, 320 insertions(+), 32 deletions(-)
copy pulsar-io/debezium/{oracle => mssql}/pom.xml (91%)
copy pulsar-io/debezium/{oracle/src/main/java/org/apache/pulsar/io/debezium/oracle/DebeziumOracleSource.java => mssql/src/main/java/org/apache/pulsar/io/debezium/mssql/DebeziumMsSqlSource.java} (86%)
copy pulsar-io/debezium/{mysql => mssql}/src/main/resources/META-INF/services/pulsar-io.yaml (85%)
copy pulsar-io/debezium/{postgres/src/main/resources/debezium-postgres-source-config.yaml => mssql/src/main/resources/debezium-mssql-source-config.yaml} (71%)
copy tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/{DebeziumOracleDbContainer.java => DebeziumMsSqlContainer.java} (58%)
create mode 100644 tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sources/debezium/DebeziumMsSqlSourceTester.java