Realizar una conmutación por error planificada al secundario AWS Región - Transmisión gestionada 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.

Realizar una conmutación por error planificada al secundario AWS Región

Puedes realizar una conmutación por error planificada para comprobar la resiliencia de tu aplicación ante un suceso inesperado en tu servidor principal AWS región en la que se encuentra su clúster de origenMSK. Una conmutación por error planificada no debería provocar la pérdida de datos.

Si utiliza una configuración de replicación de nombres de temas idénticos, siga estos pasos:

  1. Cierre todos los productores y consumidores que se conectan al clúster de origen.

  2. Cree un nuevo MSK replicador para replicar los datos de su MSK clúster de la región secundaria a su MSK clúster de la región principal con una replicación de nombres de tema idéntica (mantenga el mismo nombre de tema en la consola). Esto es necesario para copiar los datos que escribirá en la región secundaria de nuevo en la región principal, de modo que pueda conmutar por recuperación a la región principal una vez finalizado el evento inesperado.

  3. Haga que los productores y consumidores estén conectados al clúster de destino en el secundario AWS Región.

Si utilizas una configuración de nombre de tema con prefijo, sigue estos pasos para realizar la conmutación por error:

  1. Cierre todos los productores y consumidores que se conectan al clúster de origen.

  2. Cree un MSK replicador nuevo para replicar los datos de su MSK clúster de la región secundaria a su MSK clúster de la región principal. Esto es necesario para copiar los datos que escribirá en la región secundaria de nuevo en la región principal, de modo que pueda conmutar por recuperación a la región principal una vez finalizado el evento inesperado.

  3. Inicie los productores en el clúster de destino en el secundario AWS Región.

  4. En función de los requisitos de orden de mensajes de la aplicación, siga los pasos de una de las siguientes pestañas.

    No message ordering

    Si su aplicación no requiere el pedido de mensajes, inicie Consumers en el secundario AWS Región que lee tanto los temas locales (por ejemplo, un tema) como los replicados (por ejemplo,<sourceKafkaClusterAlias>.topic) mediante un operador comodín (por ejemplo,.*topic).

    Message ordering

    Si la aplicación exige ordenar los mensajes, inicie los consumidores solo para los temas replicados del clúster de destino (por ejemplo, <sourceKafkaClusterAlias>.topic), pero no para los temas locales (por ejemplo, topic).

  5. Espere a que todos los consumidores de los temas replicados del MSK clúster de destino terminen de procesar todos los datos, de modo que el retraso entre consumidores sea 0 y el número de registros procesados también sea 0. A continuación, detenga los consumidores de los temas replicados del clúster de destino. En este punto, se han consumido todos los registros que se replicaron del MSK clúster de origen al MSK clúster de destino.

  6. Haga que los consumidores se centren en los temas locales (por ejemplotopic) del MSK clúster de destino.