Jika terjadi pengecualian konsumsi pesan, Anda dapat masuk ke konsol ApsaraMQ for RocketMQ untuk melihat detail konsumen dalam grup guna mengidentifikasi kemungkinan penyebab pengecualian. Detail yang dapat dilihat mencakup status koneksi, konsistensi langganan, metrik terkait konsumsi pesan, dan informasi klien.
Skenario umum
Detail konsumen dalam grup mencakup status koneksi, langganan, transaksi penerimaan pesan per detik (TPS), jumlah pesan terakumulasi, dan informasi JStack. Informasi ini biasanya digunakan untuk mendiagnosis pengecualian dalam skenario yang dijelaskan pada tabel berikut.
Skenario | Deskripsi masalah | Saran |
Langganan tidak konsisten | Di bagian Subscriptions pada halaman Group Details dari grup yang sesuai, pesan berikut ditampilkan: Subscriptions are inconsistent. Fix the issue promptly. | Untuk informasi lebih lanjut, lihat Langganan tidak konsisten. |
Akumulasi pesan | Di halaman Group Details dari grup yang sesuai, nilai parameter Inflight Messages, Ready Messages, dan Queuing Time lebih tinggi dari yang diharapkan. | Untuk informasi lebih lanjut, lihat Bagaimana cara menangani pesan yang terakumulasi? |
Lihat informasi dasar tentang grup
Prosedur
Masuk ke Konsol ApsaraMQ for RocketMQ. Di panel navigasi sebelah kiri, klik Instances.
Di bilah navigasi atas, pilih wilayah, seperti China (Hangzhou). Di halaman Instans, klik nama instans yang ingin Anda kelola.
Di panel navigasi sebelah kiri, klik Groups. Pada halaman yang muncul, klik nama grup yang ingin Anda kelola.
Hasil kueri
Gambar berikut menunjukkan hasil kueri sampel.
Bidang | Deskripsi |
Consumer Status |
|
Consumption Mode | Mode konsumsi yang digunakan oleh konsumen untuk berlangganan pesan. ApsaraMQ for RocketMQ mendukung mode konsumsi klustering dan mode konsumsi siaran. Secara default, mode konsumsi klustering digunakan. Anda dapat memodifikasi mode konsumsi di klien. Untuk informasi lebih lanjut, lihat Konsumsi klustering dan konsumsi siaran. |
Real-time Consumption Rate | Total jumlah TPS yang digunakan oleh semua konsumen dalam grup untuk menerima pesan. |
Inflight Messages | Jumlah pesan yang sedang diproses oleh klien dan untuk mana klien belum mengembalikan hasil konsumsi. |
Ready Messages | Jumlah pesan yang terlihat oleh konsumen dan siap untuk dikonsumsi di broker ApsaraMQ for RocketMQ. |
Queuing Time | Interval antara titik waktu saat ini dan waktu siap pesan siap terlama. Metrik ini menunjukkan seberapa cepat konsumen menarik pesan. |
Subscriptions | Menampilkan apakah langganan semua konsumen dalam grup konsisten dan tag yang disubskripsikan oleh setiap konsumen. Untuk informasi tentang konsistensi langganan, lihat Konsistensi langganan. ApsaraMQ for RocketMQ memungkinkan Anda melihat hanya langganan klien yang terhubung. |
Client Connection Information | Menampilkan informasi tentang klien yang terhubung, termasuk alamat IP, versi, dan detail tumpukan setiap klien. |
Lihat informasi tentang akumulasi pesan dalam grup
Prosedur
Di halaman Groups, klik Dashboard.
Anda juga dapat menggunakan fitur dasbor untuk melihat semua metrik instans. Untuk informasi lebih lanjut, lihat Dasbor.
Hasil kueri
Dasbor grup menampilkan metrik terkait skenario konsumsi saat ini, termasuk volume akumulasi pesan, laju konsumsi pesan, serta grafik yang menunjukkan perubahan volume akumulasi pesan dan laju produksi serta konsumsi pesan dalam topik.
Jika terjadi pengecualian konsumsi, Anda dapat mendiagnosis pengecualian berdasarkan prosedur berikut:
Di Gambar 1: Indikator Skenario Konsumsi, temukan topik dengan jumlah pesan terakumulasi terbesar.
Di bagian atas halaman, pilih topik yang Anda temukan di Gambar 1 dari daftar drop-down Topik.
Lihat tren perubahan volume akumulasi pesan dan laju produksi serta konsumsi pesan di Gambar 2 dan Gambar 3 untuk mempersempit rentang waktu terjadinya pengecualian.
Tentukan apakah operasi backend dilakukan atau pengecualian jaringan terjadi selama rentang waktu tersebut.
Referensi
ApsaraMQ for RocketMQ juga memungkinkan Anda menanyakan detail konsumen dan akumulasi pesan grup dengan memanggil operasi API berikut: