某銀行收集了大量的交易資料，並使用 PutRecord 將其串流到 Amazon Kinesis Data Streams 中。在特定時間會發生網路中斷，資料工程師需要在整個處理管線中實現 exactly-once 交付語意。哪種方法可以實現這一點？

正確答案是透過在每個記錄中嵌入唯一 ID 並在處理過程中刪除重複項來設計應用程式。Kinesis Data Streams 僅保證至少一次交付，這表示在網路中斷後，資料可能會被重新處理而導致重複。透過在應用程式層級實作重複資料刪除邏輯，利用記錄中的唯一 ID，可以確保即使資料被多次傳輸，最終處理也只會發生一次，從而實現 exactly-once 語意。 其他選項的解釋： 更新檢查點配置無法保證 exactly-once 語意，它主要用於確保在故障後可以從上次檢查點恢復處理，但仍可能產生重複。 設計資料來源以避免重複攝取是理想的，但在網路不穩定或系統故障時難以完全保證，且無法解決 Kinesis 本身至少一次交付的特性。 停止使用 Kinesis Data Streams 並改用 Amazon EMR 是一個過度且不必要的解決方案，因為在 Kinesis 管道中可以透過應用程式層級的設計來實現 exactly-once 語意。