Eseguire il failback nella regione principale AWS

Se utilizzi la configurazione della replica dei nomi per argomento identico, segui questi passaggi:

1. Crea un nuovo Replicatore MSK con il cluster secondario come origine e il cluster primario come destinazione, impostando la posizione iniziale sulla replica del nome dell'argomento più antica e identica (mantieni lo stesso nome degli argomenti nella console).

   In questo modo verrà avviato il processo di copia di tutti i dati scritti nel cluster secondario dopo il failover nella regione primaria.

2. Monitora la MessageLag metrica sul nuovo replicatore in Amazon CloudWatch fino al raggiungimento0, il che indica che tutti i dati sono stati replicati dal secondario al primario.

3. Dopo che tutti i dati sono stati replicati, interrompi la connessione di tutti i produttori al cluster secondario e avvia i produttori a connettersi al cluster primario.

4. Attendi MaxOffsetLag che i tuoi consumatori si connettano al cluster secondario 0 per assicurarti di aver elaborato tutti i dati. Per informazioni, consulta Monitora i ritardi dei consumatori.

5. Una volta che tutti i dati sono stati elaborati, interrompi i consumatori nell'area secondaria e avvia i consumatori a connettersi al cluster primario per completare il failback.

6. Eliminate il replicatore creato nel primo passaggio, che consiste nella replica dei dati dal cluster secondario a quello primario.

7. Verifica che il Replicator esistente che copia i dati dal cluster primario a quello secondario abbia lo stato «RUNNING» e il ReplicatorThroughput parametro in Amazon. CloudWatch 0

   Tieni presente che quando crei un nuovo Replicator con la posizione iniziale Earliest for failback, inizia a leggere tutti i dati negli argomenti relativi ai cluster secondari. A seconda delle impostazioni di conservazione dei dati, gli argomenti possono contenere dati provenienti dal cluster di origine. Sebbene MSK Replicator filtri automaticamente tali messaggi, dovrete comunque sostenere costi di elaborazione e trasferimento dei dati per tutti i dati del cluster secondario. È possibile tenere traccia del totale dei dati elaborati dal replicatore utilizzando. ReplicatorBytesInPerSec Per informazioni, consulta Parametri del replicatore MSK.

Se utilizzi la configurazione dei nomi degli argomenti con prefisso, segui questi passaggi:

È necessario avviare le fasi di failback solo dopo che la replica dal cluster nella regione secondaria al cluster nella regione primaria è stata ripristinata e il MessageLag parametro in CloudWatch Amazon è vicino a 0. Un failback pianificato non dovrebbe comportare la perdita di dati.

1. Arresta tutti i produttori e i consumatori che si connettono al cluster MSK nella regione secondaria.

2. Per la topologia attiva-passiva, elimina il replicatore che replica i dati dal cluster nella regione secondaria alla regione primaria. Non è necessario eliminare il replicatore per la topologia attiva-attiva.

3. Avvia i produttori che si connettono al cluster MSK nella regione primaria.

4. A seconda dei requisiti di ordinamento dei messaggi dell'applicazione, segui i passaggi indicati in una delle schede seguenti.

   No message ordering

   Se la tua applicazione non richiede l'ordinamento dei messaggi, avvia i consumatori della AWS regione primaria che leggono sia gli argomenti locali (ad esempiotopic) che quelli replicati (ad esempio) utilizzando un operatore wildcard (ad esempio,<sourceKafkaClusterAlias>.topic). .*topic I consumatori sugli argomenti locali (ad esempio: topic) riprenderanno dall'ultimo offset utilizzato prima del failover. Se erano presenti dati non elaborati prima del failover, verranno elaborati ora. Nel caso di un failover pianificato, tale record non dovrebbe esistere.

   Message ordering

   1. Avvia i consumatori solo per gli argomenti replicati nella regione primaria (ad esempio, <sourceKafkaClusterAlias>.topic) ma non per gli argomenti locali (ad esempio, topic).

   2. Attendi che tutti i consumatori degli argomenti replicati sul cluster nella regione primaria completino l'elaborazione di tutti i dati, in modo che il ritardo di offset sia 0 e anche il numero di record elaborati sia 0. Quindi, interrompi i consumatori per gli argomenti replicati sul cluster nella regione primaria. A questo punto, tutti i record prodotti nella regione secondaria dopo il failover sono stati utilizzati nella regione primaria.

   3. Avvia i consumatori per gli argomenti locali (ad esempio, topic) sul cluster nella regione primaria.

5. Verificate che il replicatore esistente dal cluster nella regione primaria al cluster nella regione secondaria sia nello stato RUNNING e funzioni come previsto utilizzando le ReplicatorThroughput metriche di latenza e.