nzw921rx opened a new pull request, #10946: URL: https://github.com/apache/seatunnel/pull/10946
### Purpose of this pull request Improve Kafka E2E stability and reduce flaky failures by: - replacing blind `Thread.sleep` / `pollDelay` with condition-based waits (`Awaitility`, `awaitJobRunning`) - replacing `getServerLogs()` full-log assertions with scoped checks (`getStderr()`, log-offset slicing) to prevent cross-test false-green - replacing fixed port bindings and `/etc/hosts` manipulation in Kerberos setup with dynamic port mapping and dual Kafka listeners - replacing silent `e.printStackTrace()` with fail-fast `throw RuntimeException` on initialization errors - adding startup fail-fast (`exit 1`) in Kafka container `start.sh` when ZooKeeper or broker fails to start ### Does this PR introduce _any_ user-facing change? No. ### How was this patch tested? - Ran `KafkaIT`, `KafkaFormatIT`, `KafkaKerberosIT` locally. - Re-ran key flaky-related cases (restore path, partition expansion, Kerberos auth) to verify better stability. -- 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]
