This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from b274eb1f28 [Fix][Zeta] Preserve idle reader state after master switch
(#12042)
add a0213fb6ed [Fix][Connector-V2] Restore legacy RabbitMQ checkpoint
state (#11872)
No new revisions were added by this update.
Summary of changes:
docs/en/connectors/source/Rabbitmq.md | 11 ++
docs/zh/connectors/source/Rabbitmq.md | 9 ++
.../rabbitmq/source/RabbitmqSourceState.java | 29 ++++-
.../rabbitmq/source/RabbitmqSplitEnumerator.java | 3 +
.../rabbitmq/RabbitmqSplitEnumeratorTest.java | 41 +++++++
.../e2e/connector/rabbitmq/RabbitmqIT.java | 121 +++++++++++++++++++++
6 files changed, 211 insertions(+), 3 deletions(-)