Pantau kelambatan konsumen - 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 kelambatan konsumen

Memantau kelambatan konsumen memungkinkan Anda mengidentifikasi konsumen yang lambat atau macet yang tidak mengikuti data terbaru yang tersedia dalam suatu topik. Bila perlu, Anda kemudian dapat mengambil tindakan perbaikan, seperti menskalakan atau me-reboot konsumen tersebut. Untuk memantau kelambatan konsumen, Anda dapat menggunakan Amazon CloudWatch atau pemantauan terbuka dengan Prometheus.

Metrik lag konsumen mengukur perbedaan antara data terbaru yang ditulis ke topik Anda dan data yang dibaca oleh aplikasi Anda. Amazon MSK menyediakan metrik kelambatan konsumen berikut, yang dapat Anda dapatkan melalui Amazon CloudWatch atau melalui pemantauan terbuka dengan Prometheus:,,,, dan. EstimatedMaxTimeLag EstimatedTimeLag MaxOffsetLag OffsetLag SumOffsetLag Untuk informasi selengkapnya tentang metrik ini, lihat Metrik MSK Amazon untuk memantau pialang Standar dengan CloudWatch.

Amazon MSK mendukung metrik lag konsumen untuk cluster dengan Apache Kafka 2.2.1 atau versi yang lebih baru. Pertimbangkan poin-poin berikut saat Anda bekerja dengan Kafka dan CloudWatch metrik:

  • Metrik lag konsumen dipancarkan hanya jika grup konsumen berada dalam keadaan STABIL atau KOSONG. Grup konsumen STABIL setelah berhasil menyelesaikan penyeimbangan ulang, memastikan bahwa partisi didistribusikan secara merata di antara konsumen.

  • Metrik lag konsumen tidak ada dalam skenario berikut:

    • Jika kelompok konsumen tidak stabil.

    • Nama grup konsumen berisi titik dua (:).

    • Anda belum menetapkan offset konsumen untuk grup konsumen.

  • Nama grup konsumen digunakan sebagai dimensi untuk metrik lag konsumen di CloudWatch. Sementara Kafka mendukung karakter UTF-8 dalam nama grup konsumen, hanya CloudWatch mendukung karakter ASCII untuk nilai dimensi. Jika Anda menggunakan karakter non-ASCII dalam nama grup konsumen, hapus metrik CloudWatch lag konsumen. Untuk memastikan bahwa metrik lag konsumen Anda ditangkap dengan benar CloudWatch, Anda harus menggunakan hanya karakter ASCII dalam nama grup konsumen Anda.