You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by si...@apache.org on 2021/03/16 04:13:41 UTC

[pulsar] branch master updated (960a79e -> d0249e5)

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 960a79e  Fix message not dispatch for key_shared sub type in non-persistent su… (#9826)
     add d0249e5  [fix #9851] Add forwardSourceMessageProperty to SourceConfig (#9907)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/pulsar/admin/cli/CmdSources.java    |   6 +
 .../apache/pulsar/admin/cli/TestCmdSources.java    |  13 +-
 .../org/apache/pulsar/common/io/SourceConfig.java  |   2 +
 .../pulsar/functions/utils/SourceConfigUtils.java  |  11 ++
 .../functions/utils/SourceConfigUtilsTest.java     |   1 +
 .../tests/integration/io/TestPropertySource.java   |  29 ++--
 .../integration/io/PulsarSourcePropertyTest.java   | 169 +++++++++++++++++++++
 .../src/test/resources/pulsar-function.xml         |   1 +
 8 files changed, 217 insertions(+), 15 deletions(-)
 copy pulsar-io/data-generator/src/main/java/org/apache/pulsar/io/datagenerator/DataGeneratorSource.java => tests/docker-images/java-test-functions/src/main/java/org/apache/pulsar/tests/integration/io/TestPropertySource.java (68%)
 create mode 100644 tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/PulsarSourcePropertyTest.java