This is an automated email from the ASF dual-hosted git repository.
sanjeevrk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git.
from 5fb58d2 Fix: auto-ack flag always set true (#2496)
add affbe17 Attach Producer/Consumer property tags so its easier to
identify topics being produced/consumed by functions (#2490)
No new revisions were added by this update.
Summary of changes:
.../functions/instance/JavaInstanceRunnable.java | 6 ++++--
.../producers/AbstractOneOuputTopicProducers.java | 23 ++++++++++------------
.../MultiConsumersOneOuputTopicProducers.java | 7 +++++--
.../apache/pulsar/functions/sink/PulsarSink.java | 20 ++++++++++---------
.../pulsar/functions/source/PulsarSource.java | 15 +++++++++-----
.../MultiConsumersOneOutputTopicProducersTest.java | 2 +-
.../pulsar/functions/sink/PulsarSinkTest.java | 10 +++++-----
.../pulsar/functions/source/PulsarSourceTest.java | 10 +++++-----
8 files changed, 51 insertions(+), 42 deletions(-)
