通過DTS將RDS PostgreSQL資料同步到Kafka - Data Transmission Service

Data Transmission Service支援將PostgreSQL資料庫的資料同步至Kafka執行個體。本文以源端為RDS PostgreSQL執行個體，且目標端為阿里雲訊息佇列Kafka版執行個體為例，介紹相關操作步驟。

適用範圍

已建立儲存空間大於待同步數所需儲存空間的目標Kafka執行個體。
說明
源庫和目標庫支援的版本，請參見同步方案概覽。
目標Kafka執行個體中已建立用於接收資料的Topic。
已將源RDS PostgreSQL執行個體的wal_level參數值設定為logical。設定方式，請參見設定執行個體參數。

注意事項

源庫限制

頻寬節流設定：源庫所屬的伺服器需具備足夠出口頻寬（大於等於100 Mb/s），否則將影響資料同步速率。
同步對象限制：
- 待同步的表需具備主鍵或唯一約束，且欄位具有唯一性，否則可能會導致目標資料庫中出現重複資料。
  說明
  若接收資料的目標表不是通過DTS建立（同步類型未選中庫表結構同步），則需確保該表與源庫中待同步的表具備相同的主鍵或非空唯一約束，否則可能會導致目標資料庫中出現重複資料。
- 待同步的資料庫名稱中間不能包含短劃線（-），例如dts-testdata。
- 不支援同步TimescaleDB外掛程式表、包含跨Schema繼承關係的表與包含基於運算式的唯一索引的表。
- 通過安裝外掛程式建立的Schema不支援同步。在配置任務時，您將無法在控制台擷取相關資訊。
- 若同步對象為表層級，且需進行編輯（如表列名映射），單次同步任務的表數量超過5000時，建議您拆分待同步的表，分批配置多個任務，或者配置整庫的同步任務，否則任務提交後可能會顯示請求報錯。
WAL日誌：
- 需開啟，即設定wal_level參數的值為logical。
- 如為增量同步處理任務，DTS要求來源資料庫的WAL日誌儲存24小時以上，如為全量同步和增量同步處理任務，DTS要求來源資料庫的WAL日誌至少保留7天以上（您可在全量同步完成後將WAL日誌儲存時間設定為24小時以上），否則DTS可能因無法擷取WAL日誌而導致任務失敗，極端情況下甚至可能會導致資料不一致或丟失。由於您所設定的WAL日誌儲存時間低於DTS要求的時間進而導致的問題，不在DTS的SLA保障範圍內。
操作限制：
- 若對同步對象執行了非標準文法的DDL變更，則可能會導致同步任務失敗或資料丟失。
- 在同步執行個體運行期間，若源庫進行了大版本升級，將會導致同步執行個體運行失敗並且無法恢複，您需要重新設定同步執行個體。
- 由於源庫的邏輯訂閱本身存在使用限制，在同步執行個體運行期間，若源庫待同步的單條資料在增量變更後超過256 MB，則可能會導致同步執行個體運行失敗且無法恢複，您需要重新設定同步執行個體。
- 在庫表結構同步和全量同步階段，請勿執行庫或表結構變更的DDL操作，否則會導致資料同步任務失敗。
  說明
  在全量同步階段，DTS將對源庫進行查詢，這將產生中繼資料鎖，從而可能阻礙來源資料庫的DDL操作執行。
為保障同步任務的正常進行，避免主備切換導致的邏輯訂閱中斷，需要RDS PostgreSQL支援並開啟邏輯複製槽容錯移轉（Logical Replication Slot Failover）。
若源庫有長事務，且執行個體包含增量同步處理任務，則可能會導致源庫長事務提交前的預寫記錄檔WAL（Write-Ahead Logging）無法清理而堆積，從而造成源庫磁碟空間不足。

其他限制

單個資料同步任務僅支援同步一個資料庫中的資料。如需同步多個資料庫的資料，您需要為每個資料庫配置資料同步任務。
在如下三個情境中，您需要在源庫待同步的表寫入資料前，對其執行ALTER TABLE schema.table REPLICA IDENTITY FULL;命令，以保障該表資料同步的一致性。執行該命令期間，建議您不要有鎖表操作，否則會導致表鎖死。若在預檢查中跳過了相關檢查，DTS會在該執行個體初始化時自動化執行該命令。
- 執行個體初次運行時。
- 同步對象的選擇粒度為Schema，且在待同步的Schema中建立了新的表或使用RENAME命令重建了待同步的表時。
- 使用修改同步對象功能時。
說明
- 命令中的schema和table需要替換為待同步資料所屬的Schema名和表名。
- 建議您在業務低峰期進行操作。
DTS會在源庫中建立以下暫存資料表，用於擷取增量資料的DDL（不會將該DDL寫入到目標庫）、增量表的結構、心跳資訊等。在同步期間，請勿刪除源庫中的暫存資料表，否則會導致DTS任務異常。暫存資料表會在DTS執行個體釋放後自動刪除。
public.dts_pg_class、public.dts_pg_attribute、public.dts_pg_type、public.dts_pg_enum、public.dts_postgres_heartbeat、public.dts_ddl_command、public.dts_args_session、public.aliyun_dts_instance。
資料同步期間，DTS會在源庫建立首碼為dts_sync_的replication slot用於複製資料。通過該replication slot，DTS可以擷取源庫15分鐘內的增量日誌。當資料同步失敗或釋放同步執行個體時，DTS會嘗試主動清理該replication slot。
說明
- 如果您在資料同步期間修改了任務使用的源庫帳號密碼，或者刪除了源庫中DTS的IP白名單等，則會導致該replication slot無法自動清理。此時，您需要在源庫手動清理replication slot，以避免其持續累積佔用磁碟空間導致源庫不可用。
- 如果源庫發生了主備切換，則您需要登入備庫進行手動清理。
在全量資料初始化時，DTS將會佔用源和目標庫一定的讀寫資源，可能會導致資料庫的負載上升。因此建議在執行資料同步前評估源庫和目標庫的效能，並在業務低峰期執行資料同步（例如源庫和目標庫的CPU負載在30%以下）。
由於全量初始化會並發執行INSERT操作，導致目標資料庫的表產生片段，因此全量初始化完成後目標資料庫的表格儲存體空間會大於源庫的表格儲存體空間。
在同步執行個體運行期間：
- 若目標Kafka發生了擴容或縮容，您需要重啟同步執行個體。
- 若存在除DTS外的其他資料來源向目標庫寫入資料，則可能會導致源庫與目標庫的資料不一致，甚至會導致同步執行個體運行失敗。
DTS的校正對象為資料內容，暫不支援Sequence等中繼資料的校正，您需要自行校正。
若執行個體運行失敗，DTS技術支援人員將在8小時內嘗試恢複該執行個體。在恢複失敗執行個體的過程中，可能會對該執行個體進行重啟、調整參數等操作。
說明
在調整參數時，僅會修改DTS執行個體的參數，不會對資料庫中的參數進行修改。可能修改的參數，包括但不限於修改執行個體參數中的參數。
在同步分區表時，需將分區子表與父表同時納入同步對象，否則可能導致該分區表的資料出現不一致情況。
說明
PostgreSQL分區表的父表不直接儲存資料，所有資料實際儲存於分區子表中。同步任務需同時包含分區父表及其所有分區子表，否則可能會遺漏同步子表的資料，從而導致目標端與源端的資料不一致。

特殊情況

當源執行個體為RDS PostgreSQL時
同步期間，請勿修改RDS PostgreSQL的串連地址和可用性區域，否則會導致同步失敗。
當源執行個體為自建PostgreSQL時
需要確保max_wal_senders和max_replication_slots的參數值，均大於當前資料庫複寫槽已使用數與需要以該自建PostgreSQL為源建立的DTS執行個體數的總和。
當源執行個體為Google Cloud Platform Cloud SQL for PostgreSQL時，源庫的資料庫帳號需填入具有cloudsqlsuperuser許可權的帳號。在選擇同步對象時需選擇此帳號有許可權管理的對象，或者給此帳號添加待同步對象的Owner許可權（例如，通過GRANT <待同步對象的Owner> TO <任務使用的源庫帳號>命令，使此帳號能夠以待同步對象的Owner身份執行相關操作）。
說明
具有cloudsqlsuperuser許可權的帳號，無法管理Owner為其他cloudsqlsuperuser許可權帳號的資料。

費用說明

同步類型	鏈路配置費用
庫表結構同步和全量同步	不收費。
增量同步處理	收費，詳情請參見計費概述。

支援增量同步處理的SQL操作

操作類型	SQL動作陳述式
DML	`INSERT`、`UPDATE`、`DELETE`
DDL	僅後建立的資料同步任務，支援同步DDL操作。重要新加坡2023年05月12日前建立的資料同步任務，需在配置同步任務前，在源庫中建立觸發器和函數來捕獲DDL資訊，詳情請參見通過觸發器和函數實現PostgreSQL的DDL增量遷移。增量資料同步階段不支援同步`BIT`類型的資料。同步任務支援如下DDL，且來源資料庫帳號需為高許可權帳號，RDS PostgreSQL的小版本需大於或等於20210228，小版本的升級方式，請參見升級核心小版本。 `CREATE TABLE`、`DROP TABLE` `ALTER TABLE`（包括`RENAME TABLE`、`ADD COLUMN`、`ADD COLUMN DEFAULT`、`ALTER COLUMN TYPE`、`DROP COLUMN`、`ADD CONSTRAINT`、`ADD CONSTRAINT CHECK`、`ALTER COLUMN DROP DEFAULT`） `TRUNCATE TABLE`（源庫PostgreSQL為PostgreSQL 11及以上版本） `CREATE INDEX ON TABLE` 重要不支援同步DDL中包含的附加資訊，如`CASCADE`或`RESTRICT`等。不支援同步使用`SET session_replication_role = replica`命令的會話中的DDL。不支援同步通過調用`FUNCTION`等方式執行的DDL。若源庫單次提交的多條SQL中同時包含DML和DDL，則該DDL不會被同步。若源庫單次提交的多條SQL中包含非同步對象的DDL，則該DDL不會被同步。不支援同步通過SPI介面（Server Programming Interface）直接在外掛程式內執行的DDL。

資料庫帳號的許可權要求

資料庫	要求的權限	建立及授權方式
源RDS PostgreSQL執行個體	高許可權帳號，且需為待同步資料庫的Owner（授權帳號）。	建立帳號和建立資料庫。

操作步驟

進入目標地區的同步工作清單頁面（二選一）。
通過DTS控制台進入
1. 登入Data Transmission Service控制台。
2. 在左側導覽列，單擊資料同步。
3. 在頁面左上方，選擇同步執行個體所屬地區。
通過DMS控制台進入
說明
實際操作可能會因DMS的模式和布局不同，而有所差異。更多資訊，請參見極簡模式控制台和自訂DMS介面布局與樣式。
1. 登入Data Management服務。
2. 在頂部功能表列中，選擇Data + AI > 資料轉送（DTS） > 資料同步。
3. 在同步任務右側，選擇同步執行個體所屬地區。
單擊創建任務，進入任務配置頁面。

配置源庫及目標庫資訊。

類別	配置	說明
無	任務名稱	DTS會自動產生一個任務名稱，建議配置具有業務意義的名稱（無唯一性要求），便於後續識別。
源庫資訊	選擇已有串連資訊	若您需要使用已錄入系統（建立或儲存）的資料庫執行個體，請在下拉式清單中選擇所需的資料庫執行個體，下方的資料庫資訊將自動進行配置。說明 DMS控制台的配置項為選擇DMS資料庫執行個體。若您未將資料庫執行個體錄入到系統，或無需使用已錄入系統的資料庫執行個體，則需要手動設定下方的資料庫資訊。
	資料庫類型	選擇PostgreSQL。
	接入方式	選擇雲執行個體。
	執行個體地區	選擇源RDS PostgreSQL執行個體所屬的地區。
	是否跨阿里雲帳號	本樣本使用當前阿里雲帳號下的資料庫執行個體，需選擇不跨帳號。
	執行個體ID	選擇源RDS PostgreSQL執行個體的ID。
	資料庫名稱	填入源RDS PostgreSQL執行個體中待同步對象所屬資料庫的名稱。
	資料庫帳號	填入源RDS PostgreSQL執行個體的資料庫帳號。許可權要求，請參見資料庫帳號的許可權要求。
	資料庫密碼	填入該資料庫帳號對應的密碼。
目標庫資訊	選擇已有串連資訊	若您需要使用已錄入系統（建立或儲存）的資料庫執行個體，請在下拉式清單中選擇所需的資料庫執行個體，下方的資料庫資訊將自動進行配置。說明 DMS控制台的配置項為選擇DMS資料庫執行個體。若您未將資料庫執行個體錄入到系統，或無需使用已錄入系統的資料庫執行個體，則需要手動設定下方的資料庫資訊。
	資料庫類型	選擇Kafka。
	接入方式	選擇雲執行個體。
	執行個體地區	選擇目標Kafka執行個體所屬的地區。
	是否跨阿里雲帳號	本樣本使用當前阿里雲帳號下的資料庫執行個體，需選擇不跨帳號。
	Kafka執行個體ID	選擇目標Kafka執行個體的ID。
	串連方式	請根據Kafka執行個體實際情況、業務及安全需求進行選擇。
	Topic	在下拉框中選擇用於接收資料的Topic。
	是否使用Kafka Schema Registry	Kafka Schema Registry是中繼資料提供服務層，提供了一個RESTful介面，用於儲存和檢索Avro Schema。否：不使用Kafka Schema Registry。是：使用Kafka Schema Registry。您需要輸入Avro Schema在Kafka Schema Registry註冊的URL或IP。

配置完成後，在頁面下方單擊測試連接以進行下一步。
說明
- 請確保DTS服務的IP位址區段能夠被自動或手動添加至源庫和目標庫的安全設定中，以允許DTS伺服器的訪問。更多資訊，請參見添加DTS伺服器IP地址白名單。
- 若源庫或目標庫為自建資料庫（接入方式不是雲執行個體），則還需要在彈出的DTS伺服器訪問授權對話方塊單擊測試連接。

配置任務對象。

在對象配置頁面，配置待同步的對象。

配置	說明
同步類型	固定選中增量同步處理。預設情況下，您還需要同時選中庫表結構同步和全量同步。預檢查完成後，DTS會將源執行個體中待同步對象的全量資料在目的地組群中初始化，作為後續增量同步處理資料的基準資料。說明目標Kafka執行個體的接入方式為雲執行個體時，不支援庫表結構同步。
目標已存在表的處理模式	預檢查並報錯攔截：檢查目標資料庫中是否有同名的表。如果目標資料庫中沒有同名的表，則通過該檢查專案；如果目標資料庫中有同名的表，則在預檢查階段提示錯誤，資料同步任務不會被啟動。說明如果目標庫中同名的表不方便刪除或重新命名，您可以更改該表在目標庫中的名稱，請參見庫表列名映射。忽略報錯並繼續執行：跳過目標資料庫中是否有同名表的檢查項。警告選擇為忽略報錯並繼續執行，可能導致資料不一致，給業務帶來風險，例如：表結構一致的情況下，如在目標庫遇到與源庫主鍵或唯一鍵的值相同的記錄：全量期間，DTS會保留目的地組群中的該條記錄，即源庫中的該條記錄不會同步至目標資料庫中。增量期間，DTS不會保留目的地組群中的該條記錄，即源庫中的該條記錄會覆蓋至目標資料庫中。表結構不一致的情況下，可能會導致無法初始化資料、只能同步部分列的資料或同步失敗，請謹慎操作。
投遞到Kafka的資料格式	根據需求選擇同步到Kafka執行個體中的資料存放區格式。如果您選擇Canal JSON，Canal Json的參數說明和樣本請參見Canal Json說明。如果您選擇DTS Avro，需要根據DTS Avro的Schema定義進行資料解析，詳情請參見DTS Avro的Schema定義和DTS Avro的還原序列化樣本。如果您選擇Shareplex JSON，Shareplex Json的參數說明和樣本請參見Shareplex Json。
Kafka壓縮格式	根據需求選擇Kafka壓縮訊息的壓縮格式。 LZ4（預設）：壓縮率較低，壓縮速率較高。 GZIP：壓縮率較高，壓縮速率較低。說明對CPU的消耗較高。 Snappy：壓縮率中等，壓縮速率中等。
投遞到Kafka Partition策略	根據業務需求選擇策略。
消息確認機製	根據業務需求選擇訊息確認機制。
儲存DDL的Topic	在下拉框中選擇用於儲存DDL資訊的Topic。說明若未選擇，DDL資訊預設儲存在接收資料的Topic中。
目標庫對象名稱大小寫策略	您可以配置目標執行個體中同步對象的庫名、表名和列名的英文大小寫策略。預設情況下選擇DTS預設策略，您也可以選擇與源庫、目標庫預設策略保持一致。更多資訊，請參見目標庫對象名稱大小寫策略。
源庫對象	在源庫對象框中單擊待同步對象，然後單擊將其移動至已選擇對象框。說明在源庫對象框中，同步對象的選擇粒度為Schema或表。
已選擇對象	本樣本無需額外配置。您可以使用映射功能，設定源表在目標Kafka執行個體中的Topic名稱、Topic的Partition數量、Partition Key等資訊。更多資訊，請參見映射資訊。說明如需按庫或表層級選擇同步的SQL操作，請在已選擇對象中右擊待同步對象，並在彈出的對話方塊中選擇所需同步的SQL操作。如果使用了對象名映射功能，可能會導致依賴這個對象的其他對象同步失敗。

單擊下一步高級配置，進行進階參數配置。

配置	說明
選擇調度該任務的專屬叢集	DTS預設將任務調度到共用叢集上，您無需選擇。若您希望任務更加穩定，可以購買專屬叢集來運行DTS同步任務。更多資訊，請參見什麼是DTS專屬叢集。
源庫、目標庫無法串連後的重試時間	在同步任務啟動後，若源庫或目標庫串連失敗則DTS會報錯，並會立即進行持續的重試串連，預設持續重試時間為720分鐘，您也可以在取值範圍（10~1440分鐘）內自訂重試時間，建議設定30分鐘以上。如果DTS在設定的重試時間內重新串連上源庫、目標庫，同步任務將自動回復。否則，同步任務將會失敗。說明針對同源或者同目標的多個DTS執行個體，如DTS執行個體A和DTS執行個體B，設定網路重試時間時A設定30分鐘，B設定60分鐘，則重試時間以低的30分鐘為準。由於串連重試期間，DTS將收取任務運行費用，建議您根據業務需要自訂重試時間，或者在源和目標庫執行個體釋放後儘快釋放DTS執行個體。
源庫、目標庫出現其他問題後的重試時間	在同步任務啟動後，若源庫或目標庫出現非串連性的其他問題（如DDL或DML執行異常），則DTS會報錯並會立即進行持續的重試操作，預設持續重試時間為10分鐘，您也可以在取值範圍（1~1440分鐘）內自訂重試時間，建議設定10分鐘以上。如果DTS在設定的重試時間內相關操作執行成功，同步任務將自動回復。否則，同步任務將會失敗。重要源庫、目標庫出現其他問題後的重試時間的值需要小於源庫、目標庫無法串連後的重試時間的值。
是否限制全量同步速率	在全量同步階段，DTS將佔用源庫和目標庫一定的讀寫資源，可能會導致資料庫的負載上升。您可以根據實際情況，選擇是否對全量同步任務進行限速設定（設定每秒查詢源庫的速率QPS、每秒全量遷移的行數RPS和每秒全量遷移的數據量(MB)BPS），以緩解目標庫的壓力。說明僅當同步類型選擇了全量同步，才有此配置項。您也可以在同步執行個體運行後，調整全量同步的速率。
是否限制增量同步處理速率	您也可以根據實際情況，選擇是否對增量同步處理任務進行限速設定（設定每秒增量同步處理的行數RPS和每秒增量同步處理的數據量(MB)BPS），以緩解目標庫的壓力。
初始化時修改錶 REPLICA IDENTITY 為 FULL 的超時時間	任務初始化階段,會在源庫執行ALTER TABLE . .. REPLICA IDENTITY FULL,當前配置控制單個DDL執行最大等待時間。
初始化嗰陣修緊表 REPLICA IDENTITY 為 FULL 嘅重試時間。	該參數用於設置兩次重試之間的等待間隔,當修改複製標識的 DDL 執行超時,DTS 會按設置間隔重試此操作。
環境標籤	您可以根據實際情況，選擇用於標識執行個體的環境標籤。本樣本無需選擇。
場景標籤	您可以根據實際情況，選擇用於標識執行個體的使用情境標籤。情境標籤不會對任務正常運行有任何影響。本樣本無需選擇。
配置 ETL 功能	選擇是否配置ETL功能。關於ETL的更多資訊，請參見什麼是ETL。是：配置ETL功能，並在文字框中填寫資料處理語句，詳情請參見在DTS遷移或同步任務中配置ETL。否：不配置ETL功能。
監控警示	是否設定警示，當同步失敗或延遲超過閾值後，將通知警示連絡人。不設定：不設定警示。設定：設定警示，您還需要設定警示閾值和警示通知。更多資訊，請參見在配置任務過程中配置監控警示。

儲存任務並進行預檢查。
- 若您需要查看調用API介面配置該執行個體時的參數資訊，請將滑鼠游標移動至下一步儲存任務並預檢查按鈕上，然後單擊氣泡中的預覽OpenAPI參數。
- 若您無需查看或已完成查看API參數，請單擊頁面下方的下一步儲存任務並預檢查。
說明
- 在同步作業正式啟動之前，會先進行預檢查。只有預檢查通過後，才能成功啟動同步作業。
- 如果預檢查失敗，請單擊失敗檢查項後的查看詳情，並根據提示修複後重新進行預檢查。
- 如果預檢查產生警告：
  對於不可以忽略的檢查項，請單擊失敗檢查項後的查看詳情，並根據提示修複後重新進行預檢查。
  對於可以忽略無需修複的檢查項，您可以依次單擊點擊確認警示詳情、確認屏蔽、確定、重新進行預檢查，跳過警示檢查項重新進行預檢查。如果選擇屏蔽警示檢查項，可能會導致資料不一致等問題，給業務帶來風險。

購買執行個體。

預檢查通過率顯示為100%時，單擊下一步購買。

在購買頁面，選擇資料同步執行個體的計費方式、鏈路規格，詳細說明請參見下表。

類別	參數	說明
資訊配置	計費方式	預付費（訂用帳戶）：在建立執行個體時支付費用。適合長期需求，價格比隨用隨付更實惠，且購買時間長度越長，折扣越多。後付費（隨用隨付）：按小時計費。適合短期需求，用完可立即釋放執行個體，節省費用。
	資源群組配置	執行個體所屬的資源群組，預設為default resource group。更多資訊，請參見什麼是資源管理。
	鏈路規格	DTS為您提供了不同效能的同步規格，同步鏈路規格的不同會影響同步速率，您可以根據業務情境進行選擇。更多資訊，請參見資料同步鏈路規格說明。
	訂購時間長度	在預付費模式下，選擇訂用帳戶執行個體的時間長度和數量，包月可選擇1~9個月，包年可選擇1年、2年、3年和5年。說明該選項僅在付費類型為預付費時出現。

配置完成後，閱讀並勾選《數據傳輸（隨用隨付）服務條款》。
單擊購買並啟動，並在彈出的確認對話方塊，單擊確定。
您可在資料同步介面查看具體任務進度。

映射資訊

在已選擇對象地區框中，將滑鼠指標放置在目標Topic名（表層級）上。
單擊目標Topic名後出現的編輯。

在彈出的編輯表對話方塊中，配置映射資訊。

說明

Schema層級是編輯Schema對話方塊，且支援配置的參數少；表層級是編輯表對話方塊。
若同步對象的粒度不是整Schema，則不支援修改編輯Schema對話方塊的目標Topic名稱和設定建立Topic的Partition數量。

配置	說明
目標Topic名稱	源表同步到的目標Topic名稱，預設為源庫及目標庫配置階段在目標庫資訊選擇的Topic。重要目標端為阿里雲訊息佇列Kafka版執行個體時，填寫的Topic名稱必須在目標Kafka執行個體中真實存在，否則將會導致資料同步失敗。目標端為自建Kafka資料庫，且同步執行個體包含庫表結構任務時，DTS會嘗試在目標庫中建立您填寫的Topic。若您修改了目標Topic名稱，資料將會被寫入到您填寫的Topic中。
過濾條件	詳情請參見設定過濾條件。
設定建立Topic的Partition數量	資料寫入到目標Topic時的分區數。
Partition Key	當投遞到Kafka Partition策略選擇為按主鍵的hash值投遞到不同Partition時，您可以配置本參數，指定單個或多個列作為Partition Key來計算Hash值，DTS將根據計算得到的Hash值將不同的行投遞到目標Topic的各Partition中。說明僅支援在編輯表對話方塊勾選Partition Key。

單擊確定。

常見問題

是否支援修改Kafka壓縮格式？
支援，您可以使用修改同步對象功能進行修改。
是否支援修改消息確認機製？
支援，您可以使用修改同步對象功能進行修改。