This is an automated email from the ASF dual-hosted git repository.
davidzollo pushed a change to branch fix-rocketmq-consumer-close-ordering
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from ceca33739d Merge branch 'stabilize-rocketmq-it-namesrv-route-wait'
into fix-rocketmq-consumer-close-ordering
add 815b720cb2 [Fix][Connector-V2][RocketMQ] Isolate and parallelize
consumer thread close()
No new revisions were added by this update.
Summary of changes:
.../rocketmq/source/RocketMqSourceReader.java | 41 ++++++++-
.../source/RocketMqConsumerThreadCloseTest.java | 102 +++++++++++++++++++++
2 files changed, 140 insertions(+), 3 deletions(-)
