This is an automated email from the ASF dual-hosted git repository.
karp pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git
from 07d90dde Merge pull request #306 from starmilkxin/add_column_family
new 720ede33 [ISSUE #272]Support subscribe topic from first
new f54df9de [ISSUE #272]Support subscribe topic from first
new a9eec8c9 Merge branch 'develop_consume_first' of
github.com:Jargon9/rocketmq-streams into develop_consume_first
new f44f1f55 [ISSUE #272]Fix inner topic
new ebf53b3b [ISSUE #272] use admin to reset offset
new d90d2759 Merge branch 'develop' into develop_consume_first
new 49282601 [ISSUE #272] remove debug log
new 62f724de [ISSUE #272] add exception handle
new f5182aa1 [ISSUE #272] use admin reset offset
new 22976de3 Merge pull request #276 from Jargon9/develop_consume_first
The 811 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:
.../rocketmq/streams/core/common/Constant.java | 5 +-
.../streams/core/metadata/StreamConfig.java | 2 +
.../core/running/MessageQueueListenerWrapper.java | 12 +++-
.../streams/core/running/RocketMQClient.java | 13 ++++-
.../streams/core/running/WorkerThread.java | 66 +++++++++++++++++++++-
...ordCount.java => WordCountFromFirstOffset.java} | 16 ++++--
6 files changed, 97 insertions(+), 17 deletions(-)
copy
example/src/main/java/org/apache/rocketmq/streams/examples/{WordCount.java =>
WordCountFromFirstOffset.java} (82%)
