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/30 10:54:05 UTC

[incubator-seatunnel] branch dev updated: add kafka source doc (#1624)

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

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


The following commit(s) were added to refs/heads/dev by this push:
     new 9a4160e  add kafka source doc (#1624)
9a4160e is described below

commit 9a4160e29358a66e2da8e91f8fea51f3b838002c
Author: TrickyZerg <32...@users.noreply.github.com>
AuthorDate: Wed Mar 30 18:53:59 2022 +0800

    add kafka source doc (#1624)
---
 docs/en/connector/source/Kafka.mdx | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/docs/en/connector/source/Kafka.mdx b/docs/en/connector/source/Kafka.mdx
index 1555251..adf08fc 100644
--- a/docs/en/connector/source/Kafka.mdx
+++ b/docs/en/connector/source/Kafka.mdx
@@ -104,6 +104,15 @@ The `csv` format uses this parameter to set the separator and so on. For example
 
 - To learn more about how the `Avro Schema JSON string` should be defined, please refer to: https://avro.apache.org/docs/current/spec.html
 
+### rowtime.field [string]
+
+Extract timestamp using current configuration field for flink event time watermark
+
+### watermark [long]
+
+Sets a built-in watermark strategy for rowtime.field attributes which are out-of-order by a bounded time
+    interval. Emits watermarks which are the maximum observed timestamp minus the specified delay.
+
 ### offset.reset [string]
 
 The consumer's initial `offset` is only valid for new consumers. There are three modes