This is an automated email from the ASF dual-hosted git repository.
guangning pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 69cd6eb fix typo error (#5663)
add 8d1f793 [Issue 5474][pulsar-io-debezium] Support CDC Connector for
MongoDB (#5590)
No new revisions were added by this update.
Summary of changes:
distribution/io/src/assemble/io.xml | 1 +
.../{data-generator => debezium/mongodb}/pom.xml | 20 ++---
.../debezium/mongodb/DebeziumMongoDbSource.java} | 12 +--
.../resources/META-INF/services/pulsar-io.yaml | 6 +-
.../resources/debezium-mongodb-source-config.yaml} | 25 +++----
pulsar-io/debezium/pom.xml | 1 +
...ontainer.java => DebeziumMongoDbContainer.java} | 31 ++++----
.../integration/functions/PulsarFunctionsTest.java | 62 ++++++++++++++++
.../io/DebeziumMongoDbSourceTester.java | 85 ++++++++++++++++++++++
.../integration/io/DebeziumMySqlSourceTester.java | 18 -----
.../io/DebeziumPostgreSqlSourceTester.java | 18 -----
.../pulsar/tests/integration/io/SourceTester.java | 31 ++++++++
12 files changed, 221 insertions(+), 89 deletions(-)
copy pulsar-io/{data-generator => debezium/mongodb}/pom.xml (76%)
copy
pulsar-io/debezium/{mysql/src/main/java/org/apache/pulsar/io/debezium/mysql/DebeziumMysqlSource.java
=>
mongodb/src/main/java/org/apache/pulsar/io/debezium/mongodb/DebeziumMongoDbSource.java}
(85%)
copy pulsar-io/{aerospike =>
debezium/mongodb}/src/main/resources/META-INF/services/pulsar-io.yaml (85%)
copy
pulsar-io/debezium/{postgres/src/main/resources/debezium-postgres-source-config.yaml
=> mongodb/src/main/resources/debezium-mongodb-source-config.yaml} (65%)
copy
tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/{DebeziumMySQLContainer.java
=> DebeziumMongoDbContainer.java} (63%)
create mode 100644
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/DebeziumMongoDbSourceTester.java
