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

# 使用 MSK Replicator 建立主動-主動設定
<a name="msk-replicator-active-active"></a>

如果您想要建立主動-主動設定，其中兩個 MSK 叢集都在主動提供讀取和寫入，建議您使用具有字首主題名稱複寫的 MSK Replicator （在主控台中**將字首新增至主題名稱**)。不過，這需要您重新設定取用者以讀取複寫的主題。

依照下列步驟，在來源 MSK 叢集 A 與目標 MSK 叢集 B 之間設定主動-主動式拓樸。

1. 建立 MSK Replicator，將 MSK 叢集 A 作為來源，MSK 叢集 B 作為目標。

1. 成功建立上述 MSK Replicator 之後，請建立以叢集 B 作為來源，建立叢集 A 作為目標的複寫器。

1. 建立兩組生產者，兩組生產者可同時將資料寫入在與生產者相同區域中叢集的本機主題 (例如 "topic")。

1. 建立兩組取用者，每個取用者使用萬用字元訂閱 （例如「.\$1topic」) 從與取用者相同 AWS 區域中的 MSK 叢集讀取資料。這樣，您的取用者將自動從本機主題 (例如，`topic`) 中讀取在區域中本機產生的資料，以及從其他區域帶有字首 `<sourceKafkaClusterAlias>.topic` 的主題中複寫的資料。這兩組取用者應具有不同的取用者群組 ID，以便在 MSK Replicator 將取用者群組複製到另一個叢集時，不會覆寫取用者群組偏移。

如果您想要避免重新設定用戶端，而不是字首主題名稱複寫 (**在主控台中將字首新增至主題名稱**)，您可以使用相同的主題名稱複寫 （在主控台中**保留相同的主題名稱） **建立 MSK 複寫器，以建立主動-主動設定。不過，您將為每個複寫器支付額外的資料處理和資料傳輸費用。這是因為每個複寫器都需要處理一般資料量的兩倍，一次用於複寫，另一次用於防止無限迴圈。您可以使用 `ReplicatorBytesInPerSec` 指標追蹤每個複寫器處理的資料總量。請參閱 [監控複寫](msk-replicator-monitor.md)。此指標包含複寫至目標叢集的資料，以及 MSK Replicator 篩選的資料，以防止將資料復原至其源自的相同主題。

**注意**  
如果您使用相同的主題名稱複寫 （在主控台中**保留相同的主題名稱**) 來設定主動-主動拓撲，請在刪除主題後等待至少 30 秒，再以相同名稱重新建立主題。此等待期間有助於防止重複的訊息複寫回來源叢集。您的取用者必須能夠重新處理重複的訊息，且不影響下游。請參閱 [建置多區域 Apache Kafka 應用程式的考量事項](msk-replicator-increase-resiliency.md#msk-replication-multi-region-kafka-applications)。