View a markdown version of this page

Pantau replikasi dari cluster Kafka yang dikelola sendiri - Amazon Managed Streaming untuk Apache Kafka

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Pantau replikasi dari cluster Kafka yang dikelola sendiri

Setelah Anda membuat Replikator MSK untuk mereplikasi data dari cluster Apache Kafka yang dikelola sendiri ke broker Amazon MSK Express, pantau CloudWatch metrik Amazon berikut untuk melacak kemajuan replikasi dan menentukan kapan aplikasi Anda siap untuk bermigrasi.

Pantau status pembuatan Replicator

Setelah memanggil CreateReplicator API, Replicator bertransisi melalui status berikut:CREATING,RUNNING, atau. FAILED Biarkan sekitar 30 menit.

aws kafka describe-replicator --replicator-arn <replicator-arn>
Pantau replikasi data

Pantau metrik berikut untuk melacak kemajuan replikasi data:

  • MessageLag— Monitor hingga mencapai 0, yang menunjukkan semua data telah direplikasi.

  • ReplicationLatency— Lacak waktu yang diperlukan untuk rekaman untuk mereplikasi dari sumber ke target.

  • ReplicationFailures- Harus 0. Nilai bukan nol menunjukkan masalah replikasi.

Pantau sinkronisasi offset grup konsumen

Ketika synchroniseConsumerGroupOffsets diatur ketrue, MSK Replicator secara berkala menerjemahkan dan menyinkronkan offset grup konsumen dari sumber ke cluster target.

  • ConsumerGroupCount— Verifikasi bahwa ini cocok dengan jumlah yang diharapkan dari grup konsumen yang disinkronkan.

  • ConsumerGroupOffsetSyncFailure- Harus 0. Jika lebih besar dari 0, periksa apakah grup konsumen aktif, verifikasi izin Baca dan Jelaskan, dan pastikan topik ada di kluster target.

  • OffsetLag (MSK)dan OffsetLag (Non-MSK) — Bandingkan kelambatan konsumen tingkat partisi di kedua cluster untuk memverifikasi offset disinkronkan.

Tentukan kesiapan migrasi

Aplikasi Anda siap untuk bermigrasi ketika semua kondisi berikut terpenuhi:

  • MessageLag= 0

  • ReplicationFailures= 0

  • ConsumerGroupOffsetSyncFailure= 0