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 <[email protected]>
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
