View a markdown version of this page

Basculement planifié - 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.

Basculement planifié

Vous pouvez effectuer un basculement planifié pour tester la résilience de votre application face à un événement inattendu dans votre région principale AWS . Un basculement planifié ne doit pas entraîner de perte de données.

Identical topic name replication

  1. Arrêtez tous les producteurs et consommateurs qui se connectent à votre cluster source.

  2. Créez un nouveau réplicateur MSK pour répliquer les données de votre cluster MSK de la région secondaire vers votre cluster MSK de la région principale avec une réplication de nom de rubrique identique (conservez le même nom de rubrique dans la console). Cela est nécessaire pour copier les données écrites dans la région secondaire vers la région principale à des fins de retour sur incident.

  3. Commencez par les producteurs et les consommateurs connectés au cluster cible dans la AWS région secondaire.

Prefixed topic name replication

  1. Arrêtez tous les producteurs et consommateurs qui se connectent à votre cluster source.

  2. Créez un nouveau réplicateur MSK pour répliquer les données de votre cluster MSK de la région secondaire vers votre cluster MSK de la région principale. Cela est nécessaire pour le retour en arrière.

  3. Établissez les producteurs sur le cluster cible de la AWS région secondaire.

  4. Si votre application ne nécessite pas de classement des messages, lancez les utilisateurs de la AWS région secondaire qui lisent à la fois des sujets locaux (par exempletopic) et des sujets répliqués (par exemple,<sourceKafkaClusterAlias>.topic) en utilisant un opérateur générique (par exemple,.*topic).

    Si votre application nécessite un tri des messages, lancez les utilisateurs uniquement pour les sujets répliqués sur le cluster cible (par exemple,<sourceKafkaClusterAlias>.topic), mais pas pour les sujets locaux.

  5. Attendez que tous les utilisateurs des sujets répliqués sur le cluster MSK cible aient fini de traiter toutes les données, de sorte que le décalage entre consommateurs soit égal à 0. Arrêtez ensuite les consommateurs pour les sujets répliqués.

  6. Démarrez les consommateurs pour les rubriques locales (par exemple, topic) sur le cluster MSK cible.