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 d9d3e66164 [Fix][Connector-V2][RocketMQ] Close consumer client before
interrupting its executor
add e559edbc87 Fix spotless violations from the previous commit
No new revisions were added by this update.
Summary of changes:
.../rocketmq/source/RocketMqConsumerThread.java | 2 +-
.../rocketmq/source/RocketMqSourceReader.java | 2 +-
.../source/RocketMqConsumerThreadCloseTest.java | 18 +++++++++---------
3 files changed, 11 insertions(+), 11 deletions(-)
