This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from d91e26a336 [Fix][Connector-V2][MySQL-CDC] Keep the SET/ENUM option
list when rebuilding the source type (#12355)
add 938f29d13f [Feature][Connector-V2] Add Kafka sink connectivity dry-run
(#12400)
No new revisions were added by this update.
Summary of changes:
docs/en/connectors/sink/Kafka.md | 21 +-
docs/en/connectors/source/Kafka.md | 5 +-
docs/en/engines/zeta/user-command.md | 2 +-
docs/zh/connectors/sink/Kafka.md | 16 +
docs/zh/connectors/source/Kafka.md | 3 +-
docs/zh/engines/zeta/user-command.md | 2 +-
.../kafka/exception/KafkaConnectorException.java | 6 +
.../kafka/sink/KafkaSinkDryRunValidator.java | 185 +++++++
.../seatunnel/kafka/sink/KafkaSinkFactory.java | 19 +-
...fkaSinkWriter.java => KafkaSinkSerializer.java} | 245 +++------
.../seatunnel/kafka/sink/KafkaSinkWriter.java | 237 +--------
.../seatunnel/kafka/KafkaFactoryTest.java | 10 +
.../kafka/sink/KafkaSinkDryRunValidatorTest.java | 574 +++++++++++++++++++++
.../e2e/connector/kafka/KafkaConnectDryRunIT.java | 109 ++++
14 files changed, 1032 insertions(+), 402 deletions(-)
create mode 100644
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaSinkDryRunValidator.java
copy
seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/{KafkaSinkWriter.java
=> KafkaSinkSerializer.java} (64%)
create mode 100644
seatunnel-connectors-v2/connector-kafka/src/test/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaSinkDryRunValidatorTest.java
