This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 8183a1e SinkContext: ability to seek/pause/resume consumer for a
topic (#10498)
add 1cbd5b4 [Functions] Process async results in the same Java runnable
thread (#10618)
No new revisions were added by this update.
Summary of changes:
.../pulsar/functions/instance/JavaInstance.java | 91 +++++++++++++++-------
.../functions/instance/JavaInstanceRunnable.java | 61 ++++++++-------
.../functions/instance/JavaInstanceTest.java | 56 +++++++------
.../org/apache/pulsar/io/kinesis/KinesisSink.java | 8 +-
4 files changed, 134 insertions(+), 82 deletions(-)
