nzw921rx opened a new pull request, #11446: URL: https://github.com/apache/seatunnel/pull/11446
### Purpose of this pull request Fix a flaky RocketMQ E2E wait that was previously handled by a fixed 20-second sleep after committing consumer offsets. ### Changes - Track the consumed message queue offsets while reading RocketMQ messages. - Close the lite pull consumer in a finally block. - Replace the fixed sleep with an Awaitility wait that polls broker-visible offsets until they are synced. ### Does this PR introduce _any_ user-facing change? No. ### How was this patch tested? - ./mvnw spotless:apply - Tests were not run per request. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
