This is an automated email from the ASF dual-hosted git repository.

sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.


    from f7f2184  [Issue 5612] Use Reactivestreams client for Mongo Sink (#5635)
     add 0607600  [Issue 5832][Pulsar IO]Fix npe of debezium delete event 
(#5876)

No new revisions were added by this update.

Summary of changes:
 .../io/kafka/connect/KafkaConnectSource.java       |  8 ++-
 .../integration/functions/PulsarFunctionsTest.java | 60 ++++++++++++++++++++--
 .../io/DebeziumMongoDbSourceTester.java            | 37 +++++++++++++
 .../integration/io/DebeziumMySqlSourceTester.java  | 43 +++++++++++++---
 .../io/DebeziumPostgreSqlSourceTester.java         | 34 ++++++++++--
 .../tests/integration/io/KafkaSourceTester.java    | 15 ++++++
 .../pulsar/tests/integration/io/SourceTester.java  | 27 +++++++++-
 7 files changed, 208 insertions(+), 16 deletions(-)

Reply via email to