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(+)
