View a markdown version of this page

Conmutación por error planificada - Transmisión administrada de Amazon para Apache Kafka

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Conmutación por error planificada

Puede realizar una conmutación por error planificada para comprobar la resiliencia de su aplicación ante un suceso inesperado en su región principal. AWS Una conmutación por error planificada no debería provocar la pérdida de datos.

Identical topic name replication

  1. Cierre todos los productores y consumidores que se conecten a su clúster de origen.

  2. Cree un nuevo Replicador MSK para replicar los datos del clúster de MSK de la región secundaria al clúster de MSK de la región principal con replicación de nombres de temas idénticos (mantener el mismo nombre de tema en la consola). Esto es necesario para copiar los datos escritos en la región secundaria y devolverlos a la región principal para su recuperación por recuperación.

  3. Inicie la conexión de productores y consumidores con el clúster objetivo en la AWS región secundaria.

Prefixed topic name replication

  1. Cierre todos los productores y consumidores que se conecten a su clúster de origen.

  2. Cree un nuevo Replicador MSK para replicar los datos del clúster de MSK de la región secundaria al clúster de MSK de la región principal. Esto es necesario para la recuperación por recuperación.

  3. Inicie a los productores en el clúster objetivo de la AWS región secundaria.

  4. Si su aplicación no requiere ordenar los mensajes, utilice un operador comodín para que los consumidores de la AWS región secundaria lean tanto temas locales (por ejemplo<sourceKafkaClusterAlias>.topic) como replicados (por ejemplo). topic .*topic

    Si su aplicación requiere ordenar los mensajes, seleccione Consumers solo para los temas replicados en el clúster de destino (por ejemplo<sourceKafkaClusterAlias>.topic), pero no para los temas locales.

  5. Espere a que todos los consumidores de los temas replicados en el clúster de MSK de destino terminen de procesar todos los datos, de modo que el retraso entre los consumidores sea 0. A continuación, detenga a los consumidores por los temas replicados.

  6. Inicie los consumidores para los temas locales (por ejemplo, topic) del clúster de MSK de destino.