davidzollo commented on PR #10925: URL: https://github.com/apache/seatunnel/pull/10925#issuecomment-4976248380
Thanks for checking this. `RocketMqIT.java` is under `src/test/java` in the E2E-only module, and that module does not publish or attach a test JAR, so the changed test-helper signature is not part of SeaTunnel's public API or production artifacts. No connector API is removed. I also pushed the Kafka CI fix. SeaTunnel's Kafka source uses explicit `KafkaConsumer.assign(...)`, so consumer-group membership could never become visible through `describeConsumerGroups()`. The test now preloads records on its unique per-run topic and reads them from `earliest`, removing that impossible readiness wait while preserving the exactly-once assertion. Could you please re-review the latest head? Thanks! -- 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]
