DanielLeens opened a new pull request, #11234: URL: https://github.com/apache/seatunnel/pull/11234
### Purpose Fix an unrelated RocketMQ restore E2E CI failure where the final max-offset assertion can read `0` from a transient RocketMQ admin query even after earlier polling observed the sink topic reaching the expected offset. ### Changes - Replace the fixed post-restore sleep plus one-shot offset read with an Awaitility helper that returns the successful observed offset. - Retry `RocketMqAdminUtil.offsetTopics` because admin queries can temporarily fail during restore and broker channel transitions. - Keep the production connector code and dependencies unchanged. No `pom.xml` changes. ### Validation - `./mvnw -pl seatunnel-e2e/seatunnel-connector-v2-e2e/connector-rocketmq-e2e spotless:apply -nsu -Dmaven.gitcommitid.skip=true` - `JAVA_HOME=/Library/Java/JavaVirtualMachines/jdk1.8.0_171.jdk/Contents/Home ./mvnw -B -pl :connector-rocketmq-e2e -DskipTests -DskipITs=true -Dlicense.skipAddThirdParty=true -Dskip.ui=true -Dskip.spotless=true -Dmaven.gitcommitid.skip=true -nsu test-compile` Full Testcontainers E2E was not run locally because Docker daemon is not available on this machine (`Cannot connect to the Docker daemon`). `seatunnel-engine-ui` was not built because this change only touches a connector E2E Java test. -- 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]
