You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by rx...@apache.org on 2019/11/04 07:30:13 UTC
[pulsar] branch master updated (7275d53 -> 39af477)
This is an automated email from the ASF dual-hosted git repository.
rxl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 7275d53 fix repeated initialization of connectorsManager (#5545)
add 39af477 Add subscribe position param for consumer of sink (#5532)
No new revisions were added by this update.
Summary of changes:
.../src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java | 8 ++++++++
.../src/main/java/org/apache/pulsar/common/io/SinkConfig.java | 2 ++
.../pulsar/functions/instance/JavaInstanceRunnable.java | 11 +++++++++++
.../java/org/apache/pulsar/functions/source/PulsarSource.java | 2 ++
.../apache/pulsar/functions/source/PulsarSourceConfig.java | 2 ++
.../org/apache/pulsar/functions/source/PulsarSourceTest.java | 5 +++++
pulsar-functions/proto/src/main/proto/Function.proto | 6 ++++++
.../org/apache/pulsar/functions/utils/SinkConfigUtils.java | 7 +++++++
8 files changed, 43 insertions(+)