View a markdown version of this page

Failback - Amazon Managed Streaming for Apache Kafka

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Failback

Vous pouvez revenir à la AWS région principale une fois que l'événement de service dans cette région est terminé.

Identical topic name replication

  1. Créez un nouveau réplicateur MSK avec votre cluster secondaire comme source et votre cluster principal comme cible, la position de départ étant définie sur la réplication la plus ancienne et le nom de rubrique identique (conservez le même nom de rubrique dans la console). Cela commence à copier toutes les données écrites sur le cluster secondaire après le basculement vers la région principale.

  2. Surveillez la MessageLag métrique sur le nouveau réplicateur d'Amazon CloudWatch jusqu'à ce qu'elle soit atteinte0, ce qui indique que toutes les données ont été répliquées du secondaire au primaire.

  3. Une fois que toutes les données ont été répliquées, arrêtez tous les producteurs de se connecter au cluster secondaire et démarrez les producteurs à se connecter au cluster principal.

  4. Attendez que la MaxOffsetLag métrique que vos clients se connectent au cluster secondaire devienne 0 pour vous assurer qu'ils ont traité toutes les données. Consultez Surveillez les retards des consommateurs.

  5. Une fois que toutes les données ont été traitées, arrêtez les consommateurs de la région secondaire et commencez à se connecter au cluster principal pour effectuer le retour en arrière.

  6. Supprimez le réplicateur que vous avez créé lors de la première étape qui réplique les données de votre cluster secondaire vers le cluster principal.

  7. Vérifiez que votre réplicateur existant copiant les données du cluster principal vers le cluster secondaire a le statut « EN COURS D'EXÉCUTION » et que la ReplicatorThroughput métrique sur Amazon CloudWatch est supérieure 0 à.

    Notez que lorsque vous créez un nouveau réplicateur dont la position de départ est la plus ancienne pour le retour en arrière, il commence à lire toutes les données des rubriques de votre cluster secondaire. En fonction de vos paramètres de conservation des données, vos sujets peuvent contenir des données provenant de votre cluster source. Bien que MSK Replicator filtre automatiquement ces messages, vous devrez toujours payer des frais de traitement et de transfert pour toutes les données de votre cluster secondaire. Vous pouvez suivre le total des données traitées par le réplicateur à l'aide ReplicatorBytesInPerSec de.

Prefixed topic name replication

Vous ne devez lancer les étapes de retour en arrière qu'une fois que la réplication du cluster de la région secondaire vers le cluster de la région principale a rattrapé son retard et que la MessageLag métrique dans Amazon CloudWatch est proche de 0. Un failback planifié ne doit pas entraîner de perte de données.

  1. Fermez tous les producteurs et consommateurs se connectant au cluster MSK source dans la région secondaire.

  2. Pour une topologie active-passive, supprimez le réplicateur qui réplique les données du cluster de la région secondaire vers la région principale. Il n'est pas nécessaire de supprimer le réplicateur pour une topologie active-active.

  3. Démarrez les producteurs qui se connectent au cluster MSK cible de la région secondaire.

  4. Si votre application ne nécessite pas de classement des messages, utilisez un opérateur générique pour les utilisateurs de AWS la région principale qui lisent à la fois les sujets locaux et les sujets répliqués. Si votre application nécessite un tri des messages, commencez par sélectionner les utilisateurs uniquement pour les sujets répliqués, attendez que le décalage atteigne 0, puis passez aux sujets locaux.

  5. Vérifiez que le réplicateur existant entre le cluster de la région principale et le cluster de la région secondaire est en cours d'exécution et fonctionne comme prévu à l'aide des métriques ReplicatorThroughput et de latence.