This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong-website.git
The following commit(s) were added to refs/heads/master by this push:
new 2fe22f8764 [INLONG-541][Sort] Modify doc for importing all changelog
data into Kafka (#542)
2fe22f8764 is described below
commit 2fe22f87648e4368285e5171d7795ce88db924e8
Author: Oneal65 <[email protected]>
AuthorDate: Tue Sep 13 10:49:17 2022 +0800
[INLONG-541][Sort] Modify doc for importing all changelog data into Kafka
(#542)
---
docs/data_node/extract_node/kafka.md | 1 +
.../current/data_node/extract_node/kafka.md | 1 +
2 files changed, 2 insertions(+)
diff --git a/docs/data_node/extract_node/kafka.md
b/docs/data_node/extract_node/kafka.md
index 2a7f784e47..d843c1dec5 100644
--- a/docs/data_node/extract_node/kafka.md
+++ b/docs/data_node/extract_node/kafka.md
@@ -110,6 +110,7 @@ TODO: It will be supported in the future.
| scan.startup.specific-offsets | optional | (none) | String | Specify offsets
for each partition in case of 'specific-offsets' startup mode, e.g.
'partition:0,offset:42;partition:1,offset:300'. |
| scan.startup.timestamp-millis | optional | (none) | Long | Start from the
specified epoch timestamp (milliseconds) used in case of 'timestamp' startup
mode. |
| scan.topic-partition-discovery.interval | optional | (none) | Duration |
Interval for consumer to discover dynamically created Kafka topics and
partitions periodically. |
+| sink.ignore.changelog | optional | false | Boolean | Importing all
changelog mode data ingest into Kafka . |
## Available Metadata
diff --git
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data_node/extract_node/kafka.md
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data_node/extract_node/kafka.md
index 196a95d65a..2acd5dcb85 100644
---
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/data_node/extract_node/kafka.md
+++
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/data_node/extract_node/kafka.md
@@ -108,6 +108,7 @@ TODO: 将在未来支持此功能。
| scan.startup.specific-offsets | 可选 | (none) | String | 在使用
'specific-offsets' 启动模式时为每个 partition 指定 offset,例如
'partition:0,offset:42;partition:1,offset:300'。 |
| scan.startup.timestamp-millis | 可选 | (none) | Long | 在使用 'timestamp'
启动模式时指定启动的时间戳(单位毫秒)。 |
| scan.topic-partition-discovery.interval | 可选 | (none) | Duration | Consumer
定期探测动态创建的 Kafka topic 和 partition 的时间间隔。 |
+| sink.ignore.changelog | 可选 | false | 布尔型 | 支持所有类型的 changelog 流 ingest 到
Kafka。 |
## 可用的元数据字段