在使用Data Transmission Service將資料同步或遷移至Kafka執行個體時,您可以選擇訊息的確認機制(即Acks,發送訊息的持久化機制)。本文為您介紹DTS支援的訊息確認機制、優缺點及其適用情境。
訊息確認機制
機制名稱 | 說明 | 優缺點 | 適用情境 |
不等待任何確認 | 生產者(Producer)在發送訊息後,無需等待服務端的響應。一旦訊息被發送至服務端,生產者即認為該訊息已成功發送。 |
| 適用於對訊息可靠性要求不高的情境,例如日誌收集、監控資料等。 |
等待主節點的確認 | 生產者在發送訊息後,會等待服務端Leader副本(主副本)的確認。當Leader副本接收到訊息並將其寫入本地日誌後,將向生產者返回確認資訊。 說明 建議使用此機制。 |
| 適用於大多數情境,特別是對效能和可靠性都有一定要求的情境。 |
等待所有ISR的確認 | 生產者在發送訊息後,會等待服務端所有同步複本ISR(In-Sync Replicas)的確認。只有當所有ISR副本都成功接收到訊息並將其寫入本地日誌後,才會向生產者返回確認資訊。 |
| 適用於對訊息可靠性要求高的情境,例如金融交易、訂單處理等。 |
配置方法
您需要在配置DTS執行個體(資料同步或遷移)的對象配置階段,選擇消息確認機製。