From 4a3b9a90291adbe5b4ca8786d6b4a4c791cbbde6 Mon Sep 17 00:00:00 2001 From: Ling Jin <7138436+3AceShowHand@users.noreply.github.com> Date: Thu, 19 Sep 2024 18:48:44 +0800 Subject: [PATCH] Update ticdc/ticdc-sink-to-kafka.md Co-authored-by: Aolin --- 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 6853450f6ee6..f512e3150d77 100644 --- a/ticdc/ticdc-sink-to-kafka.md +++ b/ticdc/ticdc-sink-to-kafka.md @@ -535,7 +535,7 @@ Kafka 消费者会收到一条含有大消息在外部存储服务中的地址 } ``` -`key` 和 `value` 分别对应于 Kafka 消息中的同名字段。消费者可以通过解析这两部分的数据，还原大消息的内容。目前，只有 Open-Protocol 编码的 Kafka 消息，有 Key 字段，通过将 Key 和 Value 编码进同一个 JSON 对象，一次性发送完整的消息。对于其余协议，Key 字段总是为空。 +`key` 和 `value` 分别对应 Kafka 消息中的同名字段。消费者可以通过解析这两部分的数据，还原大消息的内容。只有 Open Protocol 编码的 Kafka 消息包含 `key` 字段。将 `key` 和 `value` 编码到同一个 JSON 对象中，一次性发送完整的消息。对于其他协议，`key` 字段始终为空。 ### 只发送 `value` 部分到外部存储