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 <liush...@foxmail.com> 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。 | ## 可用的元数据字段