From 567b0b37481467a399e80c5df52bdd47513aa04b Mon Sep 17 00:00:00 2001 From: Aolin Date: Thu, 15 Aug 2024 11:37:10 +0800 Subject: [PATCH] cdc: canal-json dml event commit-ts should be TSO (#18591) --- ticdc/ticdc-canal-json.md | 6 +++--- ticdc/ticdc-sink-to-kafka.md | 4 ++-- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/ticdc/ticdc-canal-json.md b/ticdc/ticdc-canal-json.md index c7c076298396e..c7ee505c3d922 100644 --- a/ticdc/ticdc-canal-json.md +++ b/ticdc/ticdc-canal-json.md @@ -64,7 +64,7 @@ TiCDC encodes a DDL Event into the following Canal-JSON format. "data": null, "old": null, "_tidb": { // TiDB extension field - "commitTs": 163963309467037594 + "commitTs": 429918007904436226 // A TiDB TSO timestamp } } ``` @@ -133,7 +133,7 @@ TiCDC encodes a row of DML data change event as follows: ], "old": null, "_tidb": { // TiDB extension field - "commitTs": 163963314122145239 + "commitTs": 429918007904436226 // A TiDB TSO timestamp } } ``` @@ -162,7 +162,7 @@ The following is an example of the WATERMARK Event. "data": null, "old": null, "_tidb": { // TiDB extension field - "watermarkTs": 429918007904436226 + "watermarkTs": 429918007904436226 // A TiDB TSO timestamp } } ``` diff --git a/ticdc/ticdc-sink-to-kafka.md b/ticdc/ticdc-sink-to-kafka.md index bbdebf2ca8d83..691d14a29c672 100644 --- a/ticdc/ticdc-sink-to-kafka.md +++ b/ticdc/ticdc-sink-to-kafka.md @@ -450,7 +450,7 @@ The message format with handle keys only is as follows: ], "old": null, "_tidb": { // TiDB extension fields - "commitTs": 163963314122145239, + "commitTs": 429918007904436226, // A TiDB TSO timestamp "onlyHandleKey": true } } @@ -516,7 +516,7 @@ The Kafka consumer receives a message that contains the address of the large mes ], "old": null, "_tidb": { // TiDB extension fields - "commitTs": 163963314122145239, + "commitTs": 429918007904436226, // A TiDB TSO timestamp "claimCheckLocation": "s3:/claim-check-bucket/${uuid}.json" } }