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

Posted to commits@seatunnel.apache.org by ki...@apache.org on 2022/03/29 10:32:36 UTC

[incubator-seatunnel] branch dev updated (1537758 -> 7b47c34)

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

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


    from 1537758  [Bug][seatunnel-connector-flink-KafkaSink] Use JsonRowSerializationSchema and dataStream to solve the problem that kafkaSink cannot output data.And successfully compiled locally (#1598)
     add 7b47c34  [Improvement][flink-connector-kafka] rename kafkasink/add semantic/simplify code (#1607)

No new revisions were added by this update.

Summary of changes:
 docs/en/flink/configuration/sink-plugins/Kafka.md  | 14 +++++-
 .../kafka/sink/{KafkaTable.java => KafkaSink.java} | 55 ++++++++++------------
 .../org.apache.seatunnel.flink.BaseFlinkSink       |  2 +-
 3 files changed, 38 insertions(+), 33 deletions(-)
 rename seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/kafka/sink/{KafkaTable.java => KafkaSink.java} (63%)