This is an automated email from the ASF dual-hosted git repository. karp pushed a commit to branch snapshot-1.0.4 in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git
commit f1d507c043872553fcc4841876f307ddc36d35c6 Merge: 5e91a37a ff92d26b Author: 维章 <[email protected]> AuthorDate: Mon May 30 10:16:25 2022 +0800 Merge branch 'replaceDB' into devForEnterprise .../streams/source/MessageListenerDelegator.java | 12 +++++- .../rocketmq/streams/source/RocketMQSource.java | 44 ++++++++++++++-------- .../streams/examples/join/RocketmqJoinExample.java | 2 +- .../streams/window/operator/AbstractWindow.java | 1 - 4 files changed, 40 insertions(+), 19 deletions(-)
