This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 56bca16 Update deploy-kubernetes.md (#5323)
add e5ded1b Add a source connector for MongoDB (#5316)
No new revisions were added by this update.
Summary of changes:
pulsar-io/mongo/pom.xml | 6 +-
.../org/apache/pulsar/io/mongodb/MongoConfig.java | 29 ++--
.../org/apache/pulsar/io/mongodb/MongoSink.java | 24 ++-
.../org/apache/pulsar/io/mongodb/MongoSource.java | 167 +++++++++++++++++++++
.../resources/META-INF/services/pulsar-io.yaml | 3 +-
.../apache/pulsar/io/mongodb/MongoConfigTest.java | 6 +-
.../apache/pulsar/io/mongodb/MongoSourceTest.java | 129 ++++++++++++++++
7 files changed, 330 insertions(+), 34 deletions(-)
create mode 100644
pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb/MongoSource.java
create mode 100644
pulsar-io/mongo/src/test/java/org/apache/pulsar/io/mongodb/MongoSourceTest.java
