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(-)
