goutamadwant opened a new pull request, #12400: URL: https://github.com/apache/seatunnel/pull/12400
### Purpose of this pull request Related to #10681. Add Kafka sink support for `--dry-run connect` through the existing validation SPI. Reuse the writer's serializer construction and validate Kafka metadata without creating a producer. ### Does this PR introduce _any_ user-facing change? Yes. Kafka sinks previously reported `SKIPPED`. They now validate local schema/format configuration and broker metadata. - Fixed topics: check topic existence and explicit partition bounds. - Record-dependent topics: check the referenced field and broker connectivity; target existence and partition bounds remain runtime checks. - Preserve authentication properties and bootstrap-server precedence. - Bound metadata waits, preserve interruption and close the AdminClient. - Do not produce records, create topics or initialize transactions, including in exactly-once mode. Metadata access does not establish Produce or transaction permissions. Normal writing behavior is unchanged. No new options, dependencies or public SPI changes are introduced. EN/ZH documentation describes the validation scope and limitations. ### How was this patch tested? - Factory regression fails before the change and passes afterward. - Java 8 and Java 11: all 114 Kafka connector tests pass on each JDK. - Java 8 and Java 11: all six authenticated Kafka integration tests pass on each JDK. - Integration checks verify unchanged record offsets, topic inventory and transaction inventory. - Missing topics, invalid partitions and invalid credentials fail as expected. - Fresh Java 11 74-module E2E dependency reactor passes. - Whole-repository `./mvnw -q -DskipTests verify` passes, including distribution packaging. - Spotless and whitespace checks pass. The broader build compiles tests but does not execute them. TLS and custom client extensions are not covered by the authenticated plaintext fixture. ### Check list - [x] EN/ZH connector and command documentation updated. - [x] Existing connector E2E coverage extended. - [x] No new dependency or binary package. - [x] No connector registration changes required. - [x] No incompatible normal-execution change. -- 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]
