You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by GitBox <gi...@apache.org> on 2022/06/14 01:36:52 UTC

[GitHub] [incubator-inlong-website] dockerzhang commented on a diff in pull request #392: [INLONG-391][Sort] Add some data node detail doc

dockerzhang commented on code in PR #392:
URL: https://github.com/apache/incubator-inlong-website/pull/392#discussion_r890699991


##########
docs/data_node/extract_node/kafka.md:
##########
@@ -2,7 +2,62 @@
 title: Kafka
 sidebar_position: 3
 ---
+## Overview
+
+The Kafka extract node support read data from kafka. 
 
 ## Configuration
 the Dashboard has not supported extracting data from Kafka for this version, 
-you can create Kafka data streams from the background via the [Command-line Tools](user_guide/command_line_tools.md).
\ No newline at end of file
+you can create Kafka data streams from the background via the [Command-line Tools](user_guide/command_line_tools.md).
+
+## Extract node params
+
+|  Option | Required  |  Default |  Type | Description  |
+|---|---|---|---|---|
+|id|required|(none)|String|Identifier for node|
+|name|optional|(none)|String|Node name|
+|fields|required|(none)|`List<FieldInfo>`|Table fields|
+|watermarkField|optional|(none)|WatermarkField|Defines the field for generating watermarks|
+|properties|optional|(none)|Map<String, String>|This can set other properties for connector params|
+|  topic | required  |  (none) | String  | The Kafka topic name to read|
+|   bootstrapServers| required  |  (none) | String  | Comma separated list of Kafka brokers |
+|  format | required  |  (none) | Format  | It includes `json`,`avro`,`debezium-json`,`canal-json-inlong`,`csv` |
+|kafkaScanStartupMode| required|(none)|KafkaScanStartupMode |It includes `earliest-offset` and `latest-offset`|
+|primaryKey|optional|(none)|String|It decides use what connector, there value will use upsert kafka, empty value will use kafka|
+|groupId|optional|null|String|Consumer group id. We suggest that set it by self|
+
+# Dependency

Review Comment:
   # Dependency
   ->
   ## Dependency



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@inlong.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org