This is an automated email from the ASF dual-hosted git repository.
lvyanquan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new 93d868c94 [FLINK-40983][docs] Document Kafka sink.delivery-guarantee
(#4575)
93d868c94 is described below
commit 93d868c94bfd45eb30b178aaa62370aa67bff5f1
Author: Rango <[email protected]>
AuthorDate: Thu Oct 15 14:20:12 2026 +0800
[FLINK-40983][docs] Document Kafka sink.delivery-guarantee (#4575)
---
docs/content.zh/docs/connectors/pipeline-connectors/kafka.md | 7 +++++++
docs/content/docs/connectors/pipeline-connectors/kafka.md | 7 +++++++
2 files changed, 14 insertions(+)
diff --git a/docs/content.zh/docs/connectors/pipeline-connectors/kafka.md
b/docs/content.zh/docs/connectors/pipeline-connectors/kafka.md
index bc655a5b4..13d6e37cb 100644
--- a/docs/content.zh/docs/connectors/pipeline-connectors/kafka.md
+++ b/docs/content.zh/docs/connectors/pipeline-connectors/kafka.md
@@ -150,6 +150,13 @@ Pipeline 连接器配置项
<td>String</td>
<td>自定义的上游表名到下游 Kafka Topic 名的映射关系。 每个映射关系由 `;` 分割，上游表的 TableId 和下游
Kafka 的 Topic 名由 `:` 分割。 举个例子，我们可以配置 `sink.tableId-to-topic.mapping` 的值为
`mydb.mytable1:topic1;mydb.mytable2:topic2`。 </td>
</tr>
+ <tr>
+ <td>sink.delivery-guarantee</td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">at-least-once</td>
+ <td>String</td>
+ <td>提交时的投递语义。可选值为 `exactly-once`、`at-least-once` 和 `none`，默认值为
`at-least-once`。</td>
+ </tr>
<tr>
<td>debezium-json.include-schema.enabled</td>
<td>optional</td>
diff --git a/docs/content/docs/connectors/pipeline-connectors/kafka.md
b/docs/content/docs/connectors/pipeline-connectors/kafka.md
index 2a5cc4ed5..1ee7879c0 100644
--- a/docs/content/docs/connectors/pipeline-connectors/kafka.md
+++ b/docs/content/docs/connectors/pipeline-connectors/kafka.md
@@ -148,6 +148,13 @@ Pipeline Connector Options
<td>String</td>
<td>Custom table mappings for each table from upstream tableId to
downstream Kafka topic. Each mapping is separated by `;`, separate upstream
tableId and downstream Kafka topic by `:`, For example, we can set
`sink.tableId-to-topic.mapping` like
`mydb.mytable1:topic1;mydb.mytable2:topic2`. </td>
</tr>
+ <tr>
+ <td>sink.delivery-guarantee</td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">at-least-once</td>
+ <td>String</td>
+ <td>Delivery guarantee when committing. Available options are
`exactly-once`, `at-least-once` and `none`. Default is `at-least-once`.</td>
+ </tr>
<tr>
<td>debezium-json.include-schema.enabled</td>
<td>optional</td>
