View a markdown version of this page

Monitora la replica dai cluster Kafka autogestiti - Amazon Managed Streaming per Apache Kafka

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)e OffsetLag (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= 0

  • ReplicationFailures= 0

  • ConsumerGroupOffsetSyncFailure= 0