Jika terjadi eksepsi konsumsi pesan, Anda dapat melihat status kelompok konsumen (Group) tertentu di konsol ApsaraMQ for RocketMQ. Informasi ini mencakup status online konsumen, konsistensi langganan, metrik akumulasi pesan, dan informasi klien konsumen untuk mengidentifikasi penyebab eksepsi secara cepat.
Kasus Penggunaan
Informasi status konsumen—seperti status online, langganan, TPS konsumsi, akumulasi pesan, dan informasi stack thread—sering digunakan untuk troubleshooting dalam skenario berikut:
|
Skenario |
Gejala |
Aksi yang Direkomendasikan |
|
Langganan tidak konsisten |
Pada halaman Group Details, status Subscriptions untuk kelompok konsumen menampilkan Subscriptions are inconsistent. Fix the issue promptly.. |
Lihat Inconsistent subscriptions. |
|
Akumulasi pesan |
Pada halaman Group Details, nilai Inflight Messages, Ready Messages, dan Queuing Time lebih tinggi dari yang diharapkan. |
Informasi Kelompok Konsumen
Prosedur
Masuk ke ApsaraMQ for RocketMQ console. Di panel navigasi kiri, klik Instances.
Di bilah navigasi atas, pilih wilayah, misalnya China (Hangzhou). Pada halaman Instances, klik nama instans yang ingin Anda kelola.
-
Di panel navigasi kiri, klik Groups. Lalu, pada daftar kelompok, klik kelompok target.
Hasil
Tabel berikut menjelaskan bidang-bidang pada halaman ini.
|
Bidang |
Deskripsi |
|
Consumer Status |
|
|
Consumption Mode |
Mode yang digunakan konsumen untuk berlangganan pesan. ApsaraMQ for RocketMQ mendukung mode konsumsi klustering dan mode konsumsi siaran. Mode konsumsi klustering merupakan mode default. Anda dapat mengubah mode konsumsi pada klien konsumen. Untuk informasi selengkapnya, lihat Clustering consumption and broadcasting consumption. |
|
Real-time Consumption Rate |
Total TPS konsumsi dari semua instans konsumen dalam kelompok konsumen. Satuan: pesan/detik. |
|
Inflight Messages |
Pesan yang sedang diproses oleh klien konsumen dan hasil konsumsinya belum dikembalikan. |
|
Ready Messages |
Pesan di server ApsaraMQ for RocketMQ yang siap dan tersedia untuk dikonsumsi. |
|
Queuing Time |
Waktu yang telah berlalu sejak pesan ready paling awal tersedia. Nilai ini mencerminkan ketepatan waktu penarikan pesan oleh konsumen. |
|
Subscriptions |
Menunjukkan apakah langganan instans konsumen dalam kelompok konsumen konsisten, serta menampilkan tag yang dilanggani oleh masing-masing klien konsumen. Untuk informasi selengkapnya tentang konsistensi langganan, lihat Subscription consistency. ApsaraMQ for RocketMQ hanya mendukung penayangan langganan untuk klien yang sedang online. |
|
Client Connection Information |
Menampilkan informasi klien konsumen yang sedang online, termasuk alamat IP, versi klien, dan informasi stack. |
Akumulasi Pesan
Prosedur
Pada halaman Groups, klik Dashboard.
Anda juga dapat menggunakan dashboard untuk melihat semua metrik untuk instans tertentu. Untuk informasi selengkapnya, lihat Dashboard.
Hasil
Dasbor kelompok konsumen menampilkan metrik yang terkait dengan skenario konsumsi kelompok saat ini, mencakup akumulasi pesan dan laju konsumsi untuk kelompok tersebut pada topik tertentu, serta grafik tren yang menunjukkan perubahan akumulasi pesan dan laju produksi/konsumsi untuk topik tersebut.
Jika Anda mengalami eksepsi konsumsi, ikuti langkah-langkah berikut untuk melakukan troubleshooting:
-
Pada metrik skenario konsumsi (Gambar 1), identifikasi topik dengan keterlambatan konsumsi paling signifikan (yang memiliki akumulasi pesan tertinggi).
-
Pada kriteria filter di atas grafik, pilih topik bermasalah yang telah Anda identifikasi di Gambar 1.
-
Periksa tren akumulasi pesan dan laju produksi/konsumsi untuk topik tersebut pada Gambar 2 dan 3 guna mempersempit jangka waktu terjadinya eksepsi.
-
Tentukan apakah ada operasi backend yang dilakukan atau terjadi eksepsi jaringan selama rentang waktu tersebut.
Dokumen Terkait
Selain melalui konsol, Anda dapat menggunakan operasi API untuk mengkueri status konsumsi dan akumulasi pesan kelompok konsumen.