You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by xi...@apache.org on 2021/10/14 02:05:03 UTC

[rocketmq-streams] branch main updated (f0d79a4 -> 5cb2bb0)

This is an automated email from the ASF dual-hosted git repository.

xiaodong pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git.


    from f0d79a4  Merge pull request #70 from speak2me/commit_20210922
     new 5e550a9  Add a quick start which contain some examples. (#68)
     new 3143427  Update README.md
     new 849b2dd  Update quick_start.md
     new 7cc5a19   add new examples: mutil streams clients consume same topic, do the same calculate
     new 43fce17  fix conflict: merge from mian
     new 86bf372  add read.md file illustrate
     new 5838304  modify README.md
     new 551f2b9  Merge branch 'main' into private/debug
     new 5cb2bb0  Merge pull request #75 from ni-ze/private/debug

The 165 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../streams/common/channel/sink/AbstractSink.java  | 15 +++--
 rocketmq-streams-examples/README.md                | 25 ++++++++
 .../MutilStreamsClientTest.java}                   | 67 ++++++++++----------
 .../streams/examples/mutilconsumer/Producer.java   | 71 ++++++++++++++++++++++
 .../examples/rocketmqsource/ProducerFromFile.java  |  2 +-
 5 files changed, 137 insertions(+), 43 deletions(-)
 copy rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/{checkpoint/RemoteCheckpointTest.java => mutilconsumer/MutilStreamsClientTest.java} (59%)
 create mode 100644 rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/mutilconsumer/Producer.java