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

Posted to commits@seatunnel.apache.org by zo...@apache.org on 2022/10/18 01:59:57 UTC

[incubator-seatunnel] branch dev updated (0fd8da9c1 -> 385e1f42c)

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

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


    from 0fd8da9c1 [Hotfix][SeaTunnel-Engine][Log] fix log show problem (#3118)
     add 385e1f42c [feature][connector][kafka] Support extract partition from SeaTunnelRow fields (#3085)

No new revisions were added by this update.

Summary of changes:
 docs/en/connector-v2/sink/Kafka.md                 | 24 +++++++++++++++--
 .../connectors/seatunnel/kafka/config/Config.java  |  5 ++++
 .../serialize/DefaultSeaTunnelRowSerializer.java   |  7 +++++
 .../kafka/serialize/SeaTunnelRowSerializer.java    |  9 +++++++
 .../seatunnel/kafka/sink/KafkaSinkWriter.java      | 31 +++++++++++++++++++++-
 5 files changed, 73 insertions(+), 3 deletions(-)