Führen Sie ein geplantes Failover zur sekundären AWS -Region durch - Amazon Managed Streaming für Apache Kafka

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Führen Sie ein geplantes Failover zur sekundären AWS -Region durch

Sie können einen geplanten Failover durchführen, um die Ausfallsicherheit Ihrer Anwendung gegen ein unerwartetes Ereignis in Ihrer primären AWS -Region zu testen, in der sich der Quell-MSK-Cluster befindet. Ein geplantes Failover sollte nicht zu Datenverlust führen.

Gehen Sie wie folgt vor, wenn Sie die Konfiguration für die Replikation identischer Themennamen verwenden:

  1. Fahren Sie alle Produzenten und Verbraucher herunter, die eine Verbindung zum Quell-Cluster herstellen.

  2. Erstellen Sie einen neuen MSK-Replikator, um Daten aus Ihrem MSK-Cluster in der sekundären Region auf Ihren MSK-Cluster in der primären Region mit identischer Themennamenreplikation zu replizieren (behalten Sie den gleichen Themennamen in der Konsole). Dies ist erforderlich, um die Daten, die Sie in die sekundäre Region schreiben werden, zurück in die primäre Region zu kopieren, sodass Sie nach dem Ende des unerwarteten Ereignisses ein Failback zur primären Region durchführen können.

  3. Starten Sie die Produzenten und Verbraucher, die in der sekundären AWS Region eine Verbindung zum Ziel-Cluster herstellen.

Wenn Sie die Konfiguration mit einem Themennamen mit Präfix verwenden, gehen Sie für ein Failover wie folgt vor:

  1. Fahren Sie alle Produzenten und Verbraucher herunter, die eine Verbindung zum Quell-Cluster herstellen.

  2. Erstellen Sie einen neuen MSK-Replikator, um Daten aus Ihrem MSK-Cluster in der sekundären Region auf Ihren MSK-Cluster in der primären Region zu replizieren. Dies ist erforderlich, um die Daten, die Sie in die sekundäre Region schreiben werden, zurück in die primäre Region zu kopieren, sodass Sie nach dem Ende des unerwarteten Ereignisses ein Failback zur primären Region durchführen können.

  3. Starten Sie die Produzenten auf dem Ziel-Cluster in der sekundären AWS -Region.

  4. Befolgen Sie die Schritte auf einer der folgenden Registerkarten, je nachdem, welche Anforderungen Ihre Anwendung für die Nachrichtenreihenfolge hat.

    No message ordering

    Wenn für Ihre Anwendung keine Nachrichtenreihenfolge erforderlich ist, starten Sie Verbraucher in der sekundären AWS -Region, die sowohl aus den lokalen (z. B. topic) als auch aus den replizierten Themen (z. B.<sourceKafkaClusterAlias>.topic) lesen, indem Sie einen Platzhalteroperator verwenden (z. B..*topic).

    Message ordering

    Wenn Ihre Anwendung eine Nachrichtenreihenfolge erfordert, starten Sie Verbraucher nur für die replizierten Themen auf dem Ziel-Cluster (z. B. <sourceKafkaClusterAlias>.topic), aber nicht für die lokalen Themen (z. B. topic).

  5. Warten Sie, bis alle Verbraucher replizierter Themen auf dem Ziel-MSK-Cluster die Verarbeitung aller Daten abgeschlossen haben, sodass die Verbraucherverzögerung 0 und die Anzahl der verarbeiteten Datensätze ebenfalls 0 ist. Stoppen Sie dann die Verbraucher für die replizierten Themen auf dem Ziel-Cluster. Zu diesem Zeitpunkt sind alle Datensätze, die vom Quell-MSK-Cluster auf den Ziel-MSK-Cluster repliziert wurden, verbraucht.

  6. Starten Sie die Verbraucher für die lokalen Themen (z. B. topic) auf dem Ziel-MSK-Cluster.