View a markdown version of this page

Geplantes Failover - 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.

Geplantes Failover

Sie können einen geplanten Failover durchführen, um die Widerstandsfähigkeit Ihrer Anwendung gegen ein unerwartetes Ereignis in Ihrer primären Region zu testen. AWS Ein geplantes Failover sollte nicht zu Datenverlust führen.

Identical topic name replication

  1. Fahren Sie alle Produzenten und Verbraucher herunter, die eine Verbindung zu Ihrem Quellcluster herstellen.

  2. Erstellen Sie einen neuen MSK-Replikator, um Daten von Ihrem MSK-Cluster in der sekundären Region auf Ihren MSK-Cluster in der primären Region mit identischer Themennamenreplikation zu replizieren (behalten Sie denselben Themennamen in der Konsole bei). Dies ist erforderlich, um in die sekundäre Region geschriebene Daten für ein Failback zurück in die primäre Region zu kopieren.

  3. Starten Sie Produzenten und Verbraucher, die mit dem Zielcluster in der sekundären AWS Region verbunden sind.

Prefixed topic name replication

  1. Fahren Sie alle Produzenten und Verbraucher herunter, die eine Verbindung zu Ihrem Quellcluster 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 für ein Failback erforderlich.

  3. Starten Sie die Produzenten auf dem Zielcluster in der sekundären AWS Region.

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

    Wenn Ihre Anwendung die Reihenfolge der Nachrichten erfordert, starten Sie Consumer nur für die replizierten Themen auf dem Zielcluster (z. B.<sourceKafkaClusterAlias>.topic), aber nicht für die lokalen Themen.

  5. Warten Sie, bis alle Nutzer replizierter Themen auf dem Ziel-MSK-Cluster die Verarbeitung aller Daten abgeschlossen haben, sodass der Consumer-Lag 0 ist. Stoppen Sie dann die Benutzer für die replizierten Themen.

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