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 14ba8f77 Merge pull request #293 from ni-ze/develop
new 9bfd1cb7 Filter the removeQueues from addQueues when recovering the
state
new 66637a5c Refactor the find largest queueOffset message code to use
Java Stream max() api instead of sort.
new f01fff6e Do not process the data from the removed MessageQueues by
removing the queues from the originListener first
new 979fdf5b Merge pull request #295 from Shuozeli/develop
The 787 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:
.../core/running/MessageQueueListenerWrapper.java | 17 +++++-----
.../rocketmq/streams/core/state/RocketMQStore.java | 37 ++++++----------------
2 files changed, 19 insertions(+), 35 deletions(-)
