背景信息

Kafka 是目前廣泛應(yīng)用的高性能分布式流計(jì)算平臺(tái)，數(shù)據(jù)傳輸支持 OceanBase 數(shù)據(jù)庫(kù)兩種租戶(hù)與自建 Kafka 數(shù)據(jù)源之間的數(shù)據(jù)實(shí)時(shí)同步，擴(kuò)展消息處理能力，廣泛應(yīng)用于實(shí)時(shí)數(shù)據(jù)倉(cāng)庫(kù)搭建、數(shù)據(jù)查詢(xún)和報(bào)表分流等業(yè)務(wù)場(chǎng)景。

前提條件

• 數(shù)據(jù)傳輸已具備云資源訪問(wèn)權(quán)限。詳情請(qǐng)參見(jiàn) 數(shù)據(jù)傳輸遷移角色授權(quán)。

• 已為源端 OceanBase 數(shù)據(jù)庫(kù)創(chuàng)建專(zhuān)用于數(shù)據(jù)同步任務(wù)的數(shù)據(jù)庫(kù)用戶(hù)，并為其賦予了相關(guān)權(quán)限。詳情請(qǐng)參見(jiàn) 創(chuàng)建數(shù)據(jù)庫(kù)用戶(hù)。

使用限制

• 數(shù)據(jù)同步的對(duì)象僅支持物理表，不支持其他對(duì)象。

• 數(shù)據(jù)傳輸支持的 Kafka 版本為 V0.9、V1.0 和 V2.x。

• 數(shù)據(jù)同步過(guò)程中，如果您在源端修改了同步范圍內(nèi)的表名稱(chēng)，且重命名后的名稱(chēng)不在同步對(duì)象中，則該部分?jǐn)?shù)據(jù)將不被同步至目標(biāo) Kafka 實(shí)例中。

• 待同步的表名和其中的列名不能包含中文字符。

• 數(shù)據(jù)傳輸僅支持遷移庫(kù)名、表名和列名為 ASCII 碼且不包含特殊字符（包括換行、空格，以及 .|"'`()=;/&\）的對(duì)象。

• 數(shù)據(jù)傳輸不支持 OceanBase 備庫(kù)作為源端。

注意事項(xiàng)

• 在源端為 OceanBase 數(shù)據(jù)庫(kù)并開(kāi)啟同步 DDL 的數(shù)據(jù)同步任務(wù)中，如果源端庫(kù)表發(fā)生重命名（RENAME）操作，建議您重新啟動(dòng)任務(wù)，避免增量同步丟失數(shù)據(jù)。

• 當(dāng) OceanBase 數(shù)據(jù)庫(kù) V4.x 進(jìn)行增量同步時(shí)，如果生成列沒(méi)有標(biāo)記 STORED 屬性，則同步目標(biāo)端時(shí)該列將同步為 NULL 值，導(dǎo)致下游接收該列數(shù)據(jù)時(shí)不符合預(yù)期。

• 當(dāng)更新的行包括 LOB 列時(shí)：

  • 如果 LOB 列為更新列，請(qǐng)勿依賴(lài) LOB 列在 UPDATE 或 DELETE 操作前的值。

    目前使用 LOB 列進(jìn)行存儲(chǔ)的數(shù)據(jù)類(lèi)型包括 JSON、GIS、XML、UDT（用戶(hù)定義類(lèi)型），以及 LONGTEXT、MEDIUMTEXT 等各類(lèi) TEXT。

  • 如果 LOB 列為非更新列，則在 UPDATE 或 DELETE 操作前或操作后，LOB 列的值均為 NULL。

• 節(jié)點(diǎn)之間的時(shí)鐘不同步，或者電腦終端和服務(wù)器之間的時(shí)鐘不同步，均可能導(dǎo)致增量同步的延遲時(shí)間不準(zhǔn)確。

  例如，如果時(shí)鐘早于標(biāo)準(zhǔn)時(shí)間，可能導(dǎo)致延遲時(shí)間為負(fù)數(shù)。如果時(shí)鐘晚于標(biāo)準(zhǔn)時(shí)間，可能導(dǎo)致延遲問(wèn)題。

• 當(dāng)任務(wù)意外中斷進(jìn)行斷點(diǎn)續(xù)傳時(shí)，Kafka 實(shí)例中可能會(huì)存在部分重復(fù)數(shù)據(jù)（最近一分鐘內(nèi)），因此下游系統(tǒng)需要具備排重能力。

• 同步 OceanBase 數(shù)據(jù)庫(kù)的數(shù)據(jù)至 Kafka 時(shí)，源端執(zhí)行創(chuàng)建唯一索引語(yǔ)句失敗，Kafka 會(huì)消費(fèi)到創(chuàng)建 DDL 語(yǔ)句和刪除 DDL 語(yǔ)句。如果傳到下游的創(chuàng)建索引 DDL 執(zhí)行失敗，請(qǐng)忽略該異常。

• 如果在創(chuàng)建數(shù)據(jù)同步任務(wù)時(shí)，您僅配置了 增量同步，數(shù)據(jù)傳輸要求源端數(shù)據(jù)庫(kù)的本地增量日志保存 48 小時(shí)以上。

  如果在創(chuàng)建數(shù)據(jù)同步任務(wù)時(shí)，您配置了 全量同步+增量同步，數(shù)據(jù)傳輸要求源端數(shù)據(jù)庫(kù)的本地增量日志至少保留 7 天以上。否則數(shù)據(jù)傳輸可能因無(wú)法獲取增量日志而導(dǎo)致數(shù)據(jù)同步任務(wù)失敗，甚至導(dǎo)致源端和目標(biāo)端數(shù)據(jù)不一致。

支持的源端和目標(biāo)端實(shí)例類(lèi)型

下表中，OceanBase 數(shù)據(jù)庫(kù) MySQL 租戶(hù)簡(jiǎn)稱(chēng)為 OB_MySQL，OceanBase 數(shù)據(jù)庫(kù) Oracle 租戶(hù)簡(jiǎn)稱(chēng)為 OB_Oracle。

同步 DDL 支持的范圍

• 創(chuàng)建表 CREATE TABLE

  重要

  創(chuàng)建的表需要在同步對(duì)象范圍之內(nèi)。目前僅支持對(duì)已經(jīng)同步的表進(jìn)行 DROP TABLE 操作后，再執(zhí)行 CREATE TABLE。

• 修改表 ALTER TABLE

• 刪除表 DROP TABLE

• 清空表 TRUNCATE TABLE

  說(shuō)明

  延遲刪除場(chǎng)景下，同一個(gè)事務(wù)中會(huì)有兩條一樣的 TRUNCATE TABLE DDL。此時(shí)，下游消費(fèi)需要按冪等方式處理。

• 從指定的分區(qū)中刪除數(shù)據(jù) ALTER TABLE…TRUNCATE PARTITION

• 創(chuàng)建索引 CREATE INDEX

• 刪除索引 DROP INDEX

• 添加表的備注 COMMENT ON TABLE

• 表重命名 RENAME TABLE

  重要

  重命名后的表名需要在同步對(duì)象范圍之內(nèi)。

操作步驟

1. 登錄 OceanBase 管理控制臺(tái)，購(gòu)買(mǎi)數(shù)據(jù)同步任務(wù)。

   詳情請(qǐng)參見(jiàn) 購(gòu)買(mǎi)數(shù)據(jù)同步任務(wù)。

2. 在 數(shù)據(jù)傳輸 > 數(shù)據(jù)同步 頁(yè)面，單擊新購(gòu)買(mǎi)的數(shù)據(jù)同步任務(wù)后的 配置。

   

   如果您需要引用已有的任務(wù)配置信息，可以單擊 引用配置。詳情請(qǐng)參見(jiàn) 引用和清空數(shù)據(jù)同步任務(wù)配置。

3. 在 選擇源和目標(biāo) 頁(yè)面，配置各項(xiàng)參數(shù)。

   參數(shù)	描述
   同步任務(wù)名稱(chēng)	建議使用中文、數(shù)字和字母的組合。名稱(chēng)中不能包含空格，長(zhǎng)度不能超過(guò) 64 個(gè)字符。
   標(biāo)簽（可選）	單擊文本框，在下拉列表中選擇目標(biāo)標(biāo)簽。您也可以單擊 管理標(biāo)簽，進(jìn)行新建、修改和刪除。詳情請(qǐng)參見(jiàn) 通過(guò)標(biāo)簽管理數(shù)據(jù)同步任務(wù)。
   源端	如果您已新建 OceanBase 數(shù)據(jù)源，請(qǐng)從下拉列表中進(jìn)行選擇。如果未新建，請(qǐng)單擊下拉列表中的 新建數(shù)據(jù)源，在右側(cè)對(duì)話(huà)框進(jìn)行新建。參數(shù)詳情請(qǐng)參見(jiàn) 新建 OceanBase 數(shù)據(jù)源。 重要 源端不支持 OceanBase 數(shù)據(jù)庫(kù)的 實(shí)例類(lèi)型 為 OceanBase 租戶(hù)實(shí)例。
   目標(biāo)端	如果您已新建 Kafka 數(shù)據(jù)源，請(qǐng)從下拉列表中進(jìn)行選擇。如果未新建，請(qǐng)單擊下拉列表中的 新建數(shù)據(jù)源，在右側(cè)對(duì)話(huà)框進(jìn)行新建。參數(shù)詳情請(qǐng)參見(jiàn) 新建 Kafka 數(shù)據(jù)源。

4. 單擊 下一步。在 選擇同步類(lèi)型 頁(yè)面，選擇當(dāng)前數(shù)據(jù)同步任務(wù)的同步類(lèi)型。

   

   同步類(lèi)型包括 全量同步 和 增量同步。增量同步 支持 DML 同步（包括 Insert、Delete 和 Update）和 DDL 同步，您可以根據(jù)需求進(jìn)行自定義配置。詳情請(qǐng)參見(jiàn) 自定義配置 DDL/DML。

5. 單擊 下一步。在 選擇同步對(duì)象 頁(yè)面，選擇當(dāng)前數(shù)據(jù)同步任務(wù)需要同步的對(duì)象。

   您可以通過(guò) 指定對(duì)象 和 匹配規(guī)則 兩個(gè)入口選擇同步對(duì)象。本文為您介紹通過(guò) 指定對(duì)象 方式選擇同步對(duì)象的具體操作，配置匹配規(guī)則的詳情請(qǐng)參見(jiàn) 配置匹配規(guī)則 中庫(kù)到消息隊(duì)列的通配規(guī)則說(shuō)明和配置方式。

   說(shuō)明

   如果您在 選擇同步類(lèi)型 步驟已勾選 DDL 同步，建議通過(guò)匹配規(guī)則方式選擇同步對(duì)象，以確保所有符合同步對(duì)象規(guī)則的新增對(duì)象都將被同步。如果您通過(guò)指定對(duì)象方式選擇同步對(duì)象，則新增對(duì)象或重命名后的對(duì)象將不會(huì)被同步。

   同步 OceanBase 數(shù)據(jù)庫(kù)的數(shù)據(jù)至 Kafka 時(shí)，支持多表到多 Topic 的同步。

   1. 在 選擇同步對(duì)象 區(qū)域，選中 指定對(duì)象。

   2. 在選擇區(qū)域左側(cè)選中需要同步的對(duì)象。

   3. 單擊 >。

   4. 在 將對(duì)象映射至 Topic 對(duì)話(huà)框的 已有 Topic 下拉列表中，搜索并選中需要同步的 Topic。

      

   5. 單擊 確定。

      數(shù)據(jù)傳輸支持通過(guò)文本導(dǎo)入對(duì)象，并支持對(duì)目標(biāo)端對(duì)象進(jìn)行更改 Topic、設(shè)置行過(guò)濾、移除單個(gè)對(duì)象或全部對(duì)象等操作。目標(biāo)端對(duì)象的結(jié)構(gòu)為 Topic>Database>Table。

      說(shuō)明

      通過(guò) 匹配規(guī)則 方式選擇同步對(duì)象時(shí)，重命名能力由匹配規(guī)則語(yǔ)法覆蓋，操作處僅支持設(shè)置過(guò)濾條件，以及選擇分片列和需要同步的列。詳情請(qǐng)參見(jiàn) 配置匹配規(guī)則。

      

      操作	步驟
      導(dǎo)入對(duì)象	在選擇區(qū)域的右側(cè)列表中，單擊右上角的 導(dǎo)入對(duì)象。 在對(duì)話(huà)框中，單擊 確定。 重要 導(dǎo)入會(huì)覆蓋之前的操作選擇，請(qǐng)謹(jǐn)慎操作。 在 導(dǎo)入同步對(duì)象 對(duì)話(huà)框中，導(dǎo)入需要同步的對(duì)象。 您可以通過(guò)導(dǎo)入 CSV 文件的方式進(jìn)行設(shè)置行過(guò)濾條件、設(shè)置過(guò)濾列和設(shè)置分片列等操作。詳情請(qǐng)參見(jiàn) 下載和導(dǎo)入同步對(duì)象配置。 單擊 檢驗(yàn)合法性。 通過(guò)合法性的檢驗(yàn)后，單擊 確定。
      更改 Topic	數(shù)據(jù)傳輸支持對(duì)目標(biāo)對(duì)象進(jìn)行更改 Topic 操作。詳情請(qǐng)參見(jiàn) 更改 Topic。
      設(shè)置	數(shù)據(jù)傳輸支持 WHERE 條件實(shí)現(xiàn)行過(guò)濾，并選擇分片列和需要同步的列。 在 設(shè)置 對(duì)話(huà)框中，您可以進(jìn)行以下操作。 在 行過(guò)濾條件 區(qū)域的文本框中，輸入標(biāo)準(zhǔn)的 SQL 語(yǔ)句中的 WHERE 子句，來(lái)配置行過(guò)濾。詳情請(qǐng)參見(jiàn) SQL 條件過(guò)濾數(shù)據(jù)。 在 分片列 下拉列表中，選擇目標(biāo)分片列。您可以選擇多個(gè)字段作為分片列，該參數(shù)為可選參數(shù)。 選擇分片列時(shí)，如果沒(méi)有特殊情況，默認(rèn)選擇主鍵即可。如果存在主鍵負(fù)載不均衡的情況，請(qǐng)選擇唯一性標(biāo)識(shí)且負(fù)載相對(duì)均衡的字段作為分片列，避免潛在的性能問(wèn)題。分片列的主要作用如下： 負(fù)載均衡：在目標(biāo)端可以進(jìn)行并發(fā)寫(xiě)入的情況下，通過(guò)分片列區(qū)分發(fā)送消息需要使用的特定線程。 有序性：由于存在并發(fā)寫(xiě)入可能導(dǎo)致的無(wú)序問(wèn)題，數(shù)據(jù)傳輸確保在分片列的值相同的情況下，用戶(hù)接收到的消息是有序的。此處的有序是指變更順序（DML 對(duì)于一列的執(zhí)行順序）。 在 選擇列 區(qū)域，選擇需要同步的列。詳情請(qǐng)參見(jiàn) 列過(guò)濾。
      移除/全部移除	數(shù)據(jù)傳輸支持在數(shù)據(jù)映射時(shí)，對(duì)暫時(shí)選中到目標(biāo)端的單個(gè)或多個(gè)對(duì)象進(jìn)行移除操作。 移除單個(gè)同步對(duì)象 在選擇區(qū)域的右側(cè)列表中，鼠標(biāo)懸停至目標(biāo)對(duì)象，單擊顯示的 移除，即可移除該同步對(duì)象。 移除全部同步對(duì)象 在選擇區(qū)域的右側(cè)列表中，單擊右上角的 全部移除。在對(duì)話(huà)框中，單擊 確定，即可移除全部同步對(duì)象。

6. 單擊 下一步。在 同步選項(xiàng) 頁(yè)面，配置各項(xiàng)參數(shù)。

   • 全量同步

     在 選擇同步類(lèi)型 頁(yè)面，選中 全量同步，才會(huì)顯示下述參數(shù)。

     

     參數(shù)	描述
     讀取并發(fā)配置	該參數(shù)用于配置全量同步階段從源端讀取數(shù)據(jù)的并發(fā)數(shù)，最大限制為 512.并發(fā)數(shù)過(guò)高可能會(huì)造成源端壓力過(guò)大，影響業(yè)務(wù)。
     寫(xiě)入并發(fā)配置	該參數(shù)用于配置全量同步階段往目標(biāo)端寫(xiě)入數(shù)據(jù)的并發(fā)數(shù)，最大限制為 512。并發(fā)數(shù)過(guò)高可能會(huì)造成目標(biāo)端壓力過(guò)大，影響業(yè)務(wù)。
     全量同步速率限制	您可以根據(jù)實(shí)際需求決定是否開(kāi)啟全量同步速率限制。如果開(kāi)啟，請(qǐng)?jiān)O(shè)置 RPS（全量同步階段每秒最多可以同步至目標(biāo)端的數(shù)據(jù)行數(shù)的最大值限制）和 BPS（全量同步階段每秒最多可以同步至目標(biāo)端的數(shù)據(jù)量的最大值限制）。 說(shuō)明 此處設(shè)置的 RPS 和 BPS 僅作為限速限流能力，全量同步實(shí)際可以達(dá)到的性能受限于源端、目標(biāo)端、實(shí)例規(guī)格配置等因素的影響。

   • 增量同步

     在 選擇同步類(lèi)型 頁(yè)面，選中 增量同步，才會(huì)顯示下述參數(shù)。

     

     參數(shù)	描述
     寫(xiě)入并發(fā)配置	該參數(shù)用于配置增量同步階段往目標(biāo)端寫(xiě)入數(shù)據(jù)的并發(fā)數(shù)，最大限制為 512。并發(fā)數(shù)過(guò)高可能會(huì)造成目標(biāo)端壓力過(guò)大，影響業(yè)務(wù)。
     增量同步速率限制	您可以根據(jù)實(shí)際需求決定是否開(kāi)啟增量同步速率限制。如果開(kāi)啟，請(qǐng)?jiān)O(shè)置 RPS（增量同步階段每秒最多可以同步至目標(biāo)端的數(shù)據(jù)行數(shù)的最大值限制）和 BPS（增量同步階段每秒最多可以同步至目標(biāo)端的數(shù)據(jù)量的最大值限制）。 說(shuō)明 此處設(shè)置的 RPS 和 BPS 僅作為限速限流能力，增量同步實(shí)際可以達(dá)到的性能受限于源端、目標(biāo)端、實(shí)例規(guī)格配置等因素的影響。
     增量同步起始位點(diǎn)	如果選擇同步類(lèi)型時(shí)已選擇 全量同步，該參數(shù)不會(huì)顯示。 如果選擇同步類(lèi)型時(shí)未選擇 全量同步，但選擇了 增量同步，請(qǐng)?jiān)诖颂幹付ㄍ侥硞€(gè)時(shí)間節(jié)點(diǎn)之后的數(shù)據(jù)，默認(rèn)為當(dāng)前系統(tǒng)時(shí)間。詳情請(qǐng)參見(jiàn) 設(shè)置增量同步位點(diǎn)。

   • 高級(jí)選項(xiàng)

     

     參數(shù)	描述
     序列化方式	控制數(shù)據(jù)同步至 Kafka 的消息格式，目前支持 Default、Canal、DataWorks（支持 V2.0）、SharePlex、 DefaultExtendColumnType、Debezium、DebeziumFlatten、DebeziumSmt 和 Avro。詳情請(qǐng)參見(jiàn) 數(shù)據(jù)格式說(shuō)明。 重要 目前僅 OceanBase 數(shù)據(jù)庫(kù) MySQL 租戶(hù)支持 Debezium、DebeziumFlatten、DebeziumSmt 和 Avro。 當(dāng)選擇 DataWorks 時(shí)，同步 DDL 不支持 COMMENT ON TABLE 和 ALTER TABLE…TRUNCATE PARTITION。
     分區(qū)規(guī)則	同步 OceanBase 數(shù)據(jù)庫(kù)的數(shù)據(jù)至 Kafka Topic 的規(guī)則，目前支持 Hash、Table 和 One。不同場(chǎng)景下的 DDL 語(yǔ)句投遞和示例，請(qǐng)參見(jiàn)表格下方的說(shuō)明。 Hash 表示數(shù)據(jù)傳輸使用一定的 Hash 算法，根據(jù)主鍵值或分片列值 Hash 選擇 Kafka Topic 的分區(qū)。 Table 表示數(shù)據(jù)傳輸將一張表中的全部數(shù)據(jù)投遞至同一個(gè)分區(qū)中，以表名作為 Hash 鍵。 One 表示 JSON 消息會(huì)投遞至 Topic 下的某個(gè)分區(qū)，目的是為了保持排序。
     業(yè)務(wù)系統(tǒng)標(biāo)識(shí)（可選）	僅選擇 序列化方式 為 DataWorks 時(shí)，會(huì)顯示該參數(shù)，用于標(biāo)識(shí)數(shù)據(jù)的業(yè)務(wù)系統(tǒng)來(lái)源，以便您后續(xù)進(jìn)行自定義處理。該業(yè)務(wù)系統(tǒng)標(biāo)識(shí)的長(zhǎng)度限制為 1~20 個(gè)字符。

     下表為不同場(chǎng)景的 DDL 語(yǔ)句投遞說(shuō)明。

     分區(qū)規(guī)則	DDL 語(yǔ)句涉及多張表 （例如 RENAME TABLE）	DDL 語(yǔ)句無(wú)法確認(rèn)相關(guān)表 （例如 DROP INDEX）	DDL 語(yǔ)句涉及單張表
     Hash	DDL 語(yǔ)句投遞至相關(guān)表所在 Topic 的所有分區(qū)。 例如，DDL 語(yǔ)句涉及 A、B 和 C 三張表，如果 A 在 Topic 1、B 在 Topic 2、C 不在本任務(wù)中，則該 DDL 語(yǔ)句投遞至 Topic 1 和 Topic 2 下的所有分區(qū)。	DDL 語(yǔ)句投遞至本任務(wù)所有 Topic 的所有分區(qū)。 例如，DDL 語(yǔ)句無(wú)法被數(shù)據(jù)傳輸識(shí)別，如果當(dāng)前任務(wù)存在三個(gè) Topic，則該 DDL 語(yǔ)句被投遞至這三個(gè) Topic 的所有分區(qū)。	DDL 語(yǔ)句投遞至該表所屬 Topic 下的所有分區(qū)。
     Table	DDL 語(yǔ)句投遞至相關(guān)表所在 Topic 的對(duì)應(yīng)表名 Hash 值所在的分區(qū)。 例如，DDL 語(yǔ)句涉及 A、B 和 C 三張表，如果 A 在 Topic 1、B 在 Topic 2、C 不在本任務(wù)中，則該 DDL 語(yǔ)句投遞至 Topic 1 和 Topic 2 下相關(guān)表 Hash 值所在的分區(qū)。	DDL 語(yǔ)句投遞至本任務(wù)所有 Topic 的所有分區(qū)。 例如，DDL 語(yǔ)句無(wú)法被數(shù)據(jù)傳輸識(shí)別，如果本任務(wù)存在三個(gè) Topic，則該 DDL 語(yǔ)句被投遞至這三個(gè) Topic 的所有分區(qū)。	根據(jù) Table Name 進(jìn)行 Hash，投遞至該表所屬 Topic 內(nèi)的某個(gè)分區(qū)。
     One	DDL 語(yǔ)句投遞至相關(guān)表所在 Topic 的固定分區(qū)。 例如，DDL 語(yǔ)句涉及 A、B 和 C 三張表，如果 A 在 Topic 1、B 在 Topic 2、C 不在本任務(wù)中，則該 DDL 語(yǔ)句投遞至 Topic 1 和 Topic 2 下的某個(gè)固定分區(qū)。	DDL 語(yǔ)句投遞至本任務(wù)所有 Topic 的某個(gè)固定分區(qū)。 例如，DDL 語(yǔ)句無(wú)法被數(shù)據(jù)傳輸識(shí)別，如果本任務(wù)存在三個(gè) Topic，則該 DDL 語(yǔ)句被投遞至這三個(gè) Topic 的某個(gè)固定分區(qū)。	DDL 語(yǔ)句投遞至該表所屬 Topic 下的某個(gè)固定分區(qū)。

7. 單擊 預(yù)檢查。

   在 預(yù)檢查 環(huán)節(jié)，數(shù)據(jù)傳輸會(huì)檢測(cè)和目標(biāo)端 Kafka 實(shí)例的連接情況。如果預(yù)檢查報(bào)錯(cuò)：

   • 您可以在排查并處理問(wèn)題后，重新執(zhí)行預(yù)檢查，直至預(yù)檢查成功。

   • 您也可以單擊錯(cuò)誤預(yù)檢查項(xiàng)操作列中的 跳過(guò)，會(huì)彈出對(duì)話(huà)框提示您跳過(guò)本操作的具體影響，確認(rèn)可以跳過(guò)后，請(qǐng)單擊對(duì)話(huà)框中的 確定。

8. 預(yù)檢查成功后，單擊 啟動(dòng)任務(wù)。

   如果您暫時(shí)無(wú)需啟動(dòng)任務(wù)，請(qǐng)單擊 保存。后續(xù)您只能在 同步任務(wù)列表 頁(yè)面手動(dòng)啟動(dòng)任務(wù)或通過(guò)批量操作啟動(dòng)任務(wù)。批量操作的詳情請(qǐng)參見(jiàn) 批量操作數(shù)據(jù)同步任務(wù)。

   數(shù)據(jù)傳輸支持在數(shù)據(jù)同步任務(wù)運(yùn)行過(guò)程中修改同步對(duì)象，詳情請(qǐng)參見(jiàn) 查看和修改同步對(duì)象及其過(guò)濾條件。數(shù)據(jù)同步任務(wù)啟動(dòng)后，會(huì)根據(jù)選擇的同步類(lèi)型依次執(zhí)行，詳情請(qǐng)參見(jiàn) 查看同步詳情。

如果數(shù)據(jù)同步任務(wù)運(yùn)行報(bào)錯(cuò)（通常由于網(wǎng)絡(luò)不通或進(jìn)程啟動(dòng)過(guò)慢導(dǎo)致），您可以在數(shù)據(jù)同步任務(wù)的列表或詳情頁(yè)面，單擊 恢復(fù)。

相關(guān)文檔

• 新建 OceanBase 數(shù)據(jù)源

• 新建 Kafka 數(shù)據(jù)源

• 批量操作數(shù)據(jù)同步任務(wù)

• 查看數(shù)據(jù)同步任務(wù)的詳情