執行容錯移轉至主要 AWS 區域

如果您使用的是相同的主題名稱複寫組態，請遵循下列步驟：

1. 建立新的 MSK Replicator，您的次要叢集做為來源，而主要叢集做為目標，起始位置設定為最早和相同的主題名稱複寫 (在主控台中保留相同的主題名稱)。

   這將開始複製容錯移轉回主要區域後寫入次要叢集的所有資料的程序。

2. 在 MessageLag Amazon CloudWatch 中監控新複寫器上的指標，直到達到 0，這表示所有資料已從次要複寫至主要。

3. 複寫所有資料後，停止連線至次要叢集的所有生產者，並啟動連線至主要叢集的生產者。

4. 等待連線至次要叢集的消費者成為 MaxOffsetLag 指標0，以確保他們已處理所有資料。請參閱 監控消費者延遲。

5. 處理所有資料後，停止次要區域中的取用者，並啟動連線至主要叢集的取用者以完成容錯回復。

6. 刪除您在將資料從次要叢集複寫至主要叢集的第一個步驟中建立的複寫器。

7. 確認您現有的複寫器將資料從主要叢集複製到次要叢集，在 Amazon CloudWatch 中狀態為「RUNNING」和ReplicatorThroughput指標0。

   請注意，當您建立新的複寫器，其起始位置為最早容錯回復時，它會開始讀取次要叢集主題中的所有資料。根據您的資料保留設定，您的主題可能會有來自來源叢集的資料。雖然 MSK Replicator 會自動篩選這些訊息，但您仍需支付次要叢集中所有資料的資料處理和傳輸費用。您可以使用 追蹤複寫器處理的資料總數ReplicatorBytesInPerSec。請參閱 MSK Replicator 指標。

如果您使用的是字首主題名稱組態，請遵循下列步驟：

只有在從次要區域中的叢集複寫到主要區域中的叢集已趕上，且 Amazon CloudWatch 中的 MessageLag 指標接近 0 之後，您才應該啟動容錯回復步驟。計劃的容錯恢復不會導致任何資料遺失。

1. 關閉連線至次要區域中 MSK 叢集的所有生產者和取用者。

2. 對於主動-被動式拓撲，刪除從次要區域中叢集將資料複寫到主要區域的複寫器。您不需要刪除主動-主動式拓撲的複寫器。

3. 啟動連線至主要區域中 MSK 叢集的生產者。

4. 根據應用程式的訊息順序要求而定，依照下列其中一個索引標籤中的步驟進行操作。

   No message ordering

   如果您的應用程式不需要訊息排序，請在主要 AWS 區域中使用萬用字元運算子 （例如 topic) 從本機 （例如 ) 和複寫主題 （例如 <sourceKafkaClusterAlias>.topic) 讀取的消費者.*topic開始。本機主題 (例如：topic) 上的取用者將從容錯移轉之前取用者取用的最後一個偏移恢復。如果在容錯移轉之前有任何未處理的資料，則將會立即處理該資料。如果是計劃的容錯移轉，應該沒有此類記錄。

   Message ordering

   1. 請僅針對主要區域 (例如 <sourceKafkaClusterAlias>.topic) 上的複寫主題，而非本機主題 (例如，topic) 啟動取用者。

   2. 等待主要區域中叢集上複寫主題的所有取用者完成處理所有資料，偏移延遲為 0，且處理的記錄數量也為 0。然後，停止在主要區域中叢集上複製主題的取用者。此時，容錯移轉後在次要區域中產生的所有記錄皆已在主要區域中取用。

   3. 啟動主要區域中叢集上本機主題 (例如 topic) 的取用者。

5. 確認從主要 叢集到次要 叢集的現有複寫器處於 RUNNING 狀態，並使用 ReplicatorThroughput和 延遲指標如預期般運作。