From 86e62a12e23d8c786efb8e4c77059a21e540b26a Mon Sep 17 00:00:00 2001 From: houfaxin Date: Fri, 6 Sep 2024 11:46:31 +0800 Subject: [PATCH 1/2] Update ticdc-sink-to-kafka.md --- ticdc/ticdc-sink-to-kafka.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ticdc/ticdc-sink-to-kafka.md b/ticdc/ticdc-sink-to-kafka.md index ce846e93aa12..d245b7cb0668 100644 --- a/ticdc/ticdc-sink-to-kafka.md +++ b/ticdc/ticdc-sink-to-kafka.md @@ -228,7 +228,7 @@ Topic 分发器用 topic = "xxx" 来指定，并使用 topic 表达式来实现 Topic 表达式的基本规则为 `[prefix][{schema}][middle][{table}][suffix]`，详细解释如下： - `prefix`：可选项，代表 Topic Name 的前缀。 -- `{schema}`：可选项，用于匹配库名。 +- `{schema}`：必选项，用于匹配库名。从 v7.1.4 开始，该参数为可选项。 - `middle`：可选项，代表库表名之间的分隔符。 - `{table}`：可选项，用于匹配表名。 - `suffix`：可选项，代表 Topic Name 的后缀。 From 26cf224abc16fde8e9d8a9588bc0f643261d2f32 Mon Sep 17 00:00:00 2001 From: xixirangrang Date: Fri, 6 Sep 2024 11:57:01 +0800 Subject: [PATCH 2/2] Update ticdc/ticdc-sink-to-kafka.md Co-authored-by: Ling Jin <7138436+3AceShowHand@users.noreply.github.com> --- ticdc/ticdc-sink-to-kafka.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ticdc/ticdc-sink-to-kafka.md b/ticdc/ticdc-sink-to-kafka.md index d245b7cb0668..fa3a92560847 100644 --- a/ticdc/ticdc-sink-to-kafka.md +++ b/ticdc/ticdc-sink-to-kafka.md @@ -225,7 +225,7 @@ dispatchers = [ Topic 分发器用 topic = "xxx" 来指定，并使用 topic 表达式来实现灵活的 topic 分发策略。topic 的总数建议小于 1000。 -Topic 表达式的基本规则为 `[prefix][{schema}][middle][{table}][suffix]`，详细解释如下： +Topic 表达式的基本规则为 `[prefix]{schema}[middle][{table}][suffix]`，详细解释如下： - `prefix`：可选项，代表 Topic Name 的前缀。 - `{schema}`：必选项，用于匹配库名。从 v7.1.4 开始，该参数为可选项。