ApsaraMQ for Kafka:Lihat status konsumen

Catatan

• Satu kelompok konsumen sebaiknya berlangganan tidak lebih dari tiga topik untuk mencegah akumulasi pesan.

• Saat menggunakan mode konsumsi assign, segera commit offset konsumen agar pesan yang telah dikonsumsi tidak dilaporkan sebagai terakumulasi karena offset belum di-commit.

• Jika terdapat banyak pesan yang terakumulasi, bandingkan laju konsumsi dan produksi pesan. Jika laju konsumsi lebih rendah daripada laju produksi, tingkatkan kapasitas konsumsi.

Lihat kelompok yang berlangganan ke suatu topik

1. Masuk ke ApsaraMQ for Kafka console. Pada halaman Overview, pilih wilayah di bagian Resource Distribution.

2. Pada halaman Instances, klik nama instans target.

3. Di panel navigasi sebelah kiri, klik Topics.

4. Pada halaman Topics, klik Name topik target.

5. Pada halaman Topic Details, klik tab Subscriptions.

   Daftar Online groups that subscribe to the topic menampilkan semua groups online yang berlangganan ke topik ini.

6. Pada daftar Online groups that subscribe to the topic, temukan group target lalu klik Consumer Details di kolom Actions.

   Daftar ini menampilkan detail konsumsi untuk setiap partisi topik.

   Parameter	Deskripsi
   Partition ID	ID partisi topik.
   Client	Konsumen online yang saat ini berlangganan ke topik tersebut. Catatan Nilainya dalam format <Client ID>_/<IP>. Informasi client untuk konsumen offline tidak tersedia.
   Maximum Offset	Offset konsumen maksimum untuk partisi tersebut.
   Consumer Offset	Offset konsumen saat ini untuk partisi tersebut.
   Messages Accumulated	Jumlah pesan yang terakumulasi dalam partisi tersebut. Nilai ini dihitung sebagai Maximum Offset - Consumer Offset. Penting Jumlah pesan yang terakumulasi merupakan metrik penting. Nilai yang besar mungkin menunjukkan bahwa konsumen terblokir atau laju konsumsi lebih rendah daripada laju produksi. Dalam kasus ini, analisis status konsumen Anda dan tingkatkan kapasitas konsumsi. Untuk informasi selengkapnya, lihat Reset consumer offsets.

Lihat topik yang diberlanggan oleh suatu kelompok

1. Pada halaman Instances, klik nama instans target.

2. Di panel navigasi sebelah kiri, klik Groups.

3. Pada halaman Groups, klik Group ID target.

4. Pada halaman Group Details, klik tab Consumer Status.

   Daftar ini menampilkan semua topik yang diberlanggan oleh group tersebut dan jumlah Messages Accumulated untuk setiap topik.

5. Pada daftar Topic, temukan topik target lalu klik Consumer Details di kolom Actions.

   Daftar Consumer Details menampilkan detail konsumsi group tersebut untuk setiap partisi topik.

   Untuk deskripsi parameter, lihat tabel di atas.

FAQ

Penumpukan pesan dengan konsumen yang bekerja

Konsumen mungkin menggunakan mode konsumsi assign, di mana Anda mengelola offset secara manual. Dalam kasus ini, pesan mungkin tampak terakumulasi jika offset konsumen belum di-commit, meskipun pesan tersebut telah dikonsumsi. Untuk mengatasi masalah ini, commit offset konsumen secara manual tepat waktu.

Cara meningkatkan kapasitas konsumsi

Anda dapat meningkatkan kapasitas konsumsi dengan salah satu cara berikut:

• Tingkatkan jumlah instans konsumen. Anda dapat menambahkan instans dalam satu proses—pastikan setiap instans memiliki thread-nya sendiri—atau sebarkan beberapa proses konsumen. Perhatikan bahwa jika jumlah instans konsumen melebihi jumlah partisi, kecepatan konsumsi tidak akan meningkat, dan beberapa instans akan menganggur.

• Tingkatkan jumlah thread konsumsi. Untuk informasi selengkapnya, lihat Increase consumption speed.

Apakah akumulasi pesan selalu menandakan adanya masalah?

Tidak selalu. Pertimbangkan situasi berikut:

• Waktu konsumsi terakhir masih baru-baru ini, dan jumlah pesan yang terakumulasi berfluktuasi dalam rentang stabil tanpa pertumbuhan terus-menerus. Ini normal dan menunjukkan bahwa client aktif menarik pesan terbaru.

• Jumlah pesan yang terakumulasi terus meningkat sementara offset konsumen tetap tidak berubah. Ini menunjukkan bahwa thread konsumen terblokir, berhenti memproses pesan, dan tidak lagi melakukan commit offset. Kondisi ini abnormal karena pesan benar-benar terakumulasi.

• Jumlah pesan yang terakumulasi meningkat sementara offset konsumen juga terus maju. Ini menunjukkan bahwa client masih mengonsumsi pesan, tetapi laju konsumsi lebih rendah daripada laju produksi. Anda perlu meningkatkan kapasitas konsumsi.

Untuk informasi selengkapnya, lihat Troubleshoot message accumulation in ApsaraMQ for Kafka.

Dokumen terkait

• Untuk mengkueri status konsumen menggunakan API, lihat GetConsumerProgress.

• Jika Anda tidak ingin segera memproses pesan yang terakumulasi, Anda dapat melewatkannya dengan mereset offset konsumen. Untuk informasi selengkapnya, lihat Reset consumer offsets.