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

Posted to commits@seatunnel.apache.org by fa...@apache.org on 2022/09/16 02:58:08 UTC

[incubator-seatunnel] branch dev updated (6129c0256 -> 90ce3851d)

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

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


    from 6129c0256 [Improve][Connector-V2] Refactor hdfs file sink connector code structure (#2701)
     add 90ce3851d [Improve][Connector-V2] Fix kafka connector (#2745)

No new revisions were added by this update.

Summary of changes:
 seatunnel-connectors-v2/connector-kafka/pom.xml    |  5 +++++
 .../connectors/seatunnel/kafka/config/Config.java  |  2 +-
 .../serialize/DefaultSeaTunnelRowSerializer.java   | 22 ++++++----------------
 .../seatunnel/kafka/sink/KafkaSinkWriter.java      | 17 ++++++++---------
 .../seatunnel/kafka/source/ConsumerMetadata.java   | 10 +++++-----
 .../seatunnel/kafka/source/KafkaSource.java        |  6 +++---
 .../seatunnel/kafka/source/KafkaSourceReader.java  |  2 +-
 .../kafka/source/KafkaSourceSplitEnumerator.java   |  6 +++++-
 8 files changed, 34 insertions(+), 36 deletions(-)