cdc: canal-json dml event commit-ts should be TSO (#18591) (#18602)

pingcap · Aug 15, 2024 · 8e4b616 · 8e4b616
1 parent f66d4ef
commit 8e4b616
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git 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
@@ -438,7 +438,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
     }
 }
@@ -504,7 +504,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"
     }
 }