ApsaraMQ for Kafka：Kueri pesan

Catatan

• Konsol ApsaraMQ for Kafka menampilkan maksimal 1 KB konten untuk setiap pesan yang dikueri. Konten yang melebihi 1 KB dipotong secara otomatis. Untuk melihat konten lengkap pesan, Anda dapat mengunduhnya. Ukuran maksimum pesan yang dapat diunduh adalah 10 MB. Jika pesan lebih besar dari 10 MB, hanya 10 MB pertama yang diunduh.

• Hasil kueri menampilkan maksimal 10 pesan dengan ukuran total tidak melebihi 10 MB.

  • Sebagai contoh, jika ukuran total tiga pesan pertama melebihi 10 MB, hanya dua pesan pertama yang ditampilkan.

  • Jika ukuran total 10 pesan kurang dari 10 MB, semua 10 pesan ditampilkan.

• Kemampuan Anda untuk mengkueri pesan bergantung pada kebijakan pembersihan pesan ApsaraMQ for Kafka:

  • Jika penggunaan disk kurang dari 75%, pesan yang melebihi periode retensi pesan dihapus setiap hari pukul 04.00.

  • Jika penggunaan disk antara 75% hingga 85% (tidak termasuk), pesan yang melebihi periode retensi pesan dihapus hingga penggunaan disk turun di bawah 75%.

  • Jika penggunaan disk antara 85% hingga 90% (tidak termasuk), pesan yang disimpan paling awal di-purge, terlepas dari periode retensinya.

  • Jika penggunaan disk mencapai 90% atau lebih, perlindungan tulis diaktifkan untuk menjaga stabilitas layanan, sehingga pesan baru tidak dapat ditulis.

  Penting

  Saat ApsaraMQ for Kafka melakukan purge pesan, sistem menyimpan setidaknya satu file penyimpanan. Oleh karena itu, Anda mungkin masih dapat mengkueri pesan yang telah melebihi periode retensinya.

Kueri pesan berdasarkan offset

1. Masuk ke Konsol ApsaraMQ for Kafka.

2. Di bagian Resource Distribution pada halaman Overview, pilih wilayah tempat instans ApsaraMQ for Kafka yang ingin Anda kelola berada.

3. Pada halaman Instances, klik nama instans yang ingin Anda kelola.

4. Di panel navigasi sebelah kiri, klik Message Query.

5. Pada halaman Message Query, pilih Search by offset dari daftar drop-down Search Method.

6. Di daftar Topic, pilih topik. Di daftar Partition, pilih partisi. Di kotak teks Offset, masukkan offset pesan lalu klik Search.

   Hasil menampilkan pesan pada offset yang ditentukan beserta pesan-pesan berikutnya. Misalnya, jika Anda memilih partisi 5 dan mengatur offset awal menjadi 5, hasil dimulai dari offset 5 di partisi 5.

   Tabel 1. Parameter hasil kueri

   Parameter	Deskripsi
   Partition	Partisi topik dari pesan tersebut.
   Offset	Offset pesan tersebut.
   Key	Kunci pesan. Kunci tersebut dikonversi menjadi string.
   Value	Nilai pesan, yaitu konten pesan. Nilai tersebut dikonversi menjadi string.
   Headers	Informasi header pesan. Ditampilkan sebagai pasangan kunci-nilai, seperti [trace-id=123]. Jika tidak dikonfigurasi, nilai default-nya adalah [].
   CompressionType	Jenis kompresi yang digunakan untuk pesan tersebut. Nilai default-nya adalah none, yang berarti tanpa kompresi.
   Created At	Waktu pembuatan pesan dalam objek ProducerRecord yang ditentukan oleh Anda atau disertakan oleh klien saat pesan dikirim. Catatan Jika bidang ini dikonfigurasi, nilai yang dikonfigurasi akan ditampilkan. Jika bidang ini tidak dikonfigurasi, waktu sistem saat pesan dikirim digunakan sebagai default. Jika nilai yang ditampilkan berformat 1970/x/x x:x:x, waktu pengiriman dikonfigurasi sebagai 0 atau nilai tidak valid lainnya. Klien ApsaraMQ for Kafka versi 0.9 dan sebelumnya tidak mendukung konfigurasi waktu ini.
   Actions	Klik Download Key untuk mengunduh kunci pesan. Klik Download Value untuk mengunduh konten pesan.

Kueri pesan berdasarkan waktu

Anda dapat mengkueri pesan dari semua partisi berdasarkan waktu. Jika Anda tidak mengetahui lokasi pesan tetapi mengetahui perkiraan waktu pengirimannya, tentukan titik waktu tertentu. Kueri akan mengembalikan pesan yang dikirim pada atau setelah waktu tersebut.

1. Pada halaman Message Query, pilih Search by Point in Time dari daftar drop-down Search Method.

2. Di daftar Topic, pilih topik. Di daftar Partition, pilih partisi. Di bagian Point in Time, pilih waktu lalu klik Search.

   Pesan yang dikirim pada atau setelah titik waktu yang ditentukan akan ditampilkan. Untuk informasi mengenai parameter dalam hasil kueri, lihat Parameter hasil kueri.

   • Jika Anda memilih All Partitions, pesan dari semua partisi akan ditampilkan.

   • Jika Anda memilih partisi tertentu, hanya pesan dari partisi tersebut yang ditampilkan.

Referensi

• Untuk informasi selengkapnya mengenai offset, lihat Terms.

• Untuk informasi selengkapnya mengenai detail konsumsi pesan, lihat View consumer status.