You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@seatunnel.apache.org by wa...@apache.org on 2023/04/12 06:15:38 UTC

[incubator-seatunnel] branch dev updated (8f6822ea2 -> 884f733c3)

This is an automated email from the ASF dual-hosted git repository.

wanghailin pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


    from 8f6822ea2 [Hotfix][Zeta] Fix the bug of parsing multi sinks (#4554)
     add 884f733c3 [Improve][connector][kafka] Set default value for partition option (#4524)

No new revisions were added by this update.

Summary of changes:
 .../seatunnel/kafka/sink/KafkaSinkFactory.java     |  5 +--
 .../seatunnel/kafka/sink/KafkaSinkWriter.java      | 18 ++++++++---
 .../seatunnel/e2e/connector/kafka/KafkaIT.java     | 36 ++++++++++++++++++++++
 ....conf => kafka_default_sink_fake_to_kafka.conf} |  3 +-
 4 files changed, 54 insertions(+), 8 deletions(-)
 copy seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/resources/{kafkaTextsink_fake_to_kafka.conf => kafka_default_sink_fake_to_kafka.conf} (95%)