View a markdown version of this page

計劃的容錯移轉 - Amazon Managed Streaming for Apache Kafka

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

計劃的容錯移轉

您可以執行計劃的容錯移轉，以針對主要區域中的意外事件測試應用程式的彈性 AWS 。計劃的容錯移轉不應導致資料遺失。

Identical topic name replication

  1. 關閉所有連接到來源叢集的生產者和消費者。

  2. 建立新的 MSK Replicator，以使用相同的主題名稱複寫 (在主控台中保留相同的主題名稱），將資料從次要區域中的 MSK 叢集複寫到主要區域中的 MSK 叢集。這是將寫入次要區域的資料複製回主要區域以進行容錯回復所必需的。

  3. 啟動連接到次要 AWS 區域中目標叢集的生產者和消費者。

Prefixed topic name replication

  1. 關閉所有連接到來源叢集的生產者和消費者。

  2. 建立新的 MSK Replicator，從次要區域中的 MSK 叢集將資料複寫至主要區域中的 MSK 叢集。這是容錯回復的必要項目。

  3. 在次要 AWS 區域的目標叢集上啟動生產者。

  4. 如果您的應用程式不需要訊息排序，請在從本機 （例如，topic) 和複寫主題 （例如，<sourceKafkaClusterAlias>.topic) 讀取的次要 AWS 區域中，使用萬用字元運算子 （例如，) 啟動消費者.*topic。

    如果您的應用程式需要訊息排序，請僅針對目標叢集上的複寫主題 （例如 <sourceKafkaClusterAlias>.topic) 啟動取用者，而非本機主題。

  5. 等待目標 MSK 叢集上複寫主題的所有取用者完成處理所有資料，因此取用者延遲為 0。然後，停止複寫主題的取用者。

  6. 啟動目標 MSK 叢集上本機主題 (例如 topic) 的取用者。