Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
Monitora la replica dai cluster Kafka autogestiti
Dopo aver creato un replicatore MSK per replicare i dati da un cluster Apache Kafka autogestito ai broker Amazon MSK Express, monitora i seguenti CloudWatch parametri Amazon per monitorare l'avanzamento della replica e determinare quando le applicazioni sono pronte per la migrazione.
Monitora lo stato di creazione di Replicator
Dopo aver chiamato l'CreateReplicatorAPI, il Replicator passa attraverso i seguenti stati:CREATING,, RUNNING o. FAILED Attendere circa 30 minuti.
aws kafka describe-replicator --replicator-arn <replicator-arn>
Monitora la replica dei dati
Monitora le seguenti metriche per tenere traccia dell'avanzamento della replica dei dati:
MessageLag— Monitora fino a raggiungere lo 0, il che indica che tutti i dati sono stati replicati.ReplicationLatency— Tieni traccia del tempo impiegato dalla replica dei record dall'origine alla destinazione.ReplicationFailures— Dovrebbe essere 0. Un valore diverso da zero indica problemi di replica.
Monitora la sincronizzazione degli offset dei gruppi di consumatori
Quando synchroniseConsumerGroupOffsets è impostato sutrue, MSK Replicator traduce e sincronizza periodicamente gli offset del gruppo di consumatori dal cluster di origine a quello di destinazione.
ConsumerGroupCount— Verificare che ciò corrisponda al numero previsto di gruppi di consumatori da sincronizzare.ConsumerGroupOffsetSyncFailure— Dovrebbe essere 0. Se maggiore di 0, verifica che i gruppi di consumatori siano attivi, verifica le autorizzazioni di lettura e descrizione e assicurati che gli argomenti esistano nel cluster di destinazione.OffsetLag (MSK)eOffsetLag (Non-MSK)— Confronta il ritardo dei consumatori a livello di partizione in entrambi i cluster per verificare che gli offset siano sincronizzati.
Determina la preparazione alla migrazione
Le tue applicazioni sono pronte per la migrazione quando vengono soddisfatte tutte le seguenti condizioni:
MessageLag= 0ReplicationFailures= 0ConsumerGroupOffsetSyncFailure= 0