ApsaraMQ for Kafka：Lihat detail konsumen

Catatan penggunaan

• Disarankan agar setiap grup hanya berlangganan maksimal tiga topik untuk mencegah akumulasi pesan.

• Jika menggunakan mode assign untuk mengonsumsi pesan, segera lakukan commit offset konsumen secara manual untuk mencegah akumulasi pesan karena offset yang belum dicommit.

• Jika terjadi akumulasi pesan dalam jumlah besar, periksa laju konsumsi dan produksi pesan. Jika laju konsumsi lebih rendah daripada laju produksi, disarankan untuk meningkatkan kapasitas konsumsi konsumen guna menyelesaikan masalah tersebut.

Lihat grup konsumen yang berlangganan ke sebuah topik

1. Masuk ke Konsol ApsaraMQ for Kafka. Di bagian Resource Distribution halaman Overview, pilih wilayah tempat instance ApsaraMQ for Kafka yang ingin dikelola berada.

2. Di halaman Instances, klik nama instance yang ingin dikelola.

3. Di panel navigasi sisi kiri, klik Topics.

4. Di halaman Topics, klik nama topik yang ingin dikelola.

5. Di halaman Topic Details, klik tab Subscriptions.

   Semua grup yang berlangganan ke topik ditampilkan di bagian Online groups that subscribe to the topic.

6. Di bagian Online groups that subscribe to the topic, temukan grup yang ingin dikelola dan klik Consumer Details di kolom Actions.

   Di halaman Detail Konsumen, detail konsumen grup di setiap partisi topik ditampilkan. Tabel berikut menjelaskan parameter-parameter tersebut.

   

   Parameter	Deskripsi
   Partition ID	ID partisi.
   Client	ID konsumen terhubung yang berlangganan ke topik. Catatan Nilainya dalam format <Client ID>_/<IP address>. Anda tidak dapat melihat ID konsumen yang terputus.
   Maximum Offset	Offset maksimum dari mana pesan dapat dikonsumsi di partisi.
   Consumer Offset	Offset dari mana pesan dikonsumsi di partisi.
   Messages Accumulated	Jumlah total pesan yang terakumulasi di partisi. Nilainya sama dengan offset maksimum dikurangi offset konsumen. Penting Parameter ini adalah metrik utama. Jika sejumlah besar pesan terakumulasi, konsumen mungkin diblokir atau laju konsumsi tidak dapat mengimbangi laju produksi. Dalam hal ini, Anda harus menganalisis status konsumen dan meningkatkan laju konsumsi. Untuk informasi lebih lanjut, lihat Reset offset konsumen.

Lihat topik yang dilanggan oleh sebuah grup

1. Di halaman Instances, klik nama instance yang ingin dikelola.

2. Di panel navigasi sisi kiri, klik Groups.

3. Di halaman Groups, klik ID grup yang ingin dikelola.

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

   Semua topik yang dilanggan oleh grup dan pesan terakumulasi di setiap topik ditampilkan dalam daftar.

5. Di kolom Topic, temukan topik yang ingin dikelola dan klik Consumer Details di kolom Actions.

   Di halaman Consumer Details, detail konsumen untuk grup di setiap partisi topik yang sesuai ditampilkan.

   Untuk informasi lebih lanjut tentang parameter, lihat bagian sebelumnya.

Tanya Jawab Umum

Mengapa konsumsi pesan di aplikasi hilir tidak terpengaruh oleh akumulasi pesan di partisi ApsaraMQ for Kafka?

Mode assign mungkin digunakan oleh aplikasi hilir untuk mengonsumsi pesan. Dalam mode ini, Anda mengelola offset. Dalam kasus ini, pesan mungkin dikonsumsi tetapi masih ditampilkan sebagai terakumulasi karena offset yang belum dicommit. Disarankan untuk segera melakukan commit offset secara manual guna menyelesaikan masalah akumulasi pesan.

Bagaimana cara meningkatkan kapasitas konsumsi konsumen jika pesan terakumulasi karena laju konsumsi pesan lebih rendah daripada laju produksi pesan?

Anda dapat menggunakan salah satu metode berikut untuk meningkatkan kapasitas konsumsi konsumen:

• Tambah jumlah konsumen. Anda dapat menambah konsumen dalam proses dan pastikan setiap konsumen sesuai dengan satu thread. Atau, Anda dapat menerapkan beberapa proses konsumen. Jika jumlah konsumen melebihi jumlah partisi, laju konsumsi tidak dapat ditingkatkan. Sebaliknya, konsumen tertentu menjadi idle.

• Tambah jumlah thread konsumsi. Untuk informasi lebih lanjut, lihat Tingkatkan Laju Konsumsi.

Apakah akumulasi pesan menunjukkan masalah dalam sistem?

Tidak. Akumulasi pesan menunjukkan hal yang berbeda berdasarkan situasi:

• Jika waktu konsumsi terbaru mendekati waktu saat ini dan jumlah pesan terakumulasi berfluktuasi dalam rentang stabil yang diharapkan, klien sedang menarik pesan baru. Dalam hal ini, akumulasi pesan normal.

• Jika jumlah pesan terakumulasi bertambah secara bertahap dan offset konsumen tetap tidak berubah, thread konsumen di klien terblokir, dan klien berhenti mengonsumsi pesan dan melakukan commit offset konsumen ke broker. Dalam hal ini, akumulasi pesan abnormal.

• Jika jumlah pesan terakumulasi bertambah secara bertahap dan offset konsumen sedang dicommit, klien masih mengonsumsi pesan, tetapi laju konsumsi pesan lebih rendah daripada laju produksi pesan. Dalam hal ini, akumulasi pesan abnormal.

Untuk informasi lebih lanjut, lihat Apa yang harus saya lakukan jika pesan terakumulasi ketika saya menggunakan ApsaraMQ for Kafka?.

Referensi

• Untuk informasi tentang cara memanggil operasi API yang sesuai untuk menanyakan detail konsumen, lihat GetConsumerProgress.

• Jika Anda tidak ingin menangani pesan terakumulasi, Anda dapat melewati pesan terakumulasi dengan mereset offset konsumen. Untuk informasi lebih lanjut, lihat Reset Offset Konsumen.