ApsaraMQ for Kafka：Bagaimana cara melakukan pengujian cepat pada broker Message Queue for Apache Kafka?

Prosedur

Untuk melakukan pengujian cepat pada broker ApsaraMQ for Kafka, ikuti langkah-langkah berikut:

1. Buat topik

2. Kirim pesan

3. Lihat status partisi

4. Kueri pesan berdasarkan offset

Anda dapat mengulangi Langkah 2 hingga Langkah 4 beberapa kali. Jika semua langkah berhasil, broker berfungsi sesuai harapan.

Buat topik

1. Masuk ke konsol ApsaraMQ for Kafka.

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

   Penting

   Topik harus dibuat di wilayah tempat instance Elastic Compute Service (ECS) Anda diterapkan karena topik tidak dapat digunakan lintas wilayah. Misalnya, jika produsen dan konsumen berjalan di instance ECS di wilayah China (Beijing), topik juga harus dibuat di wilayah tersebut.

3. Di halaman Instances, klik nama instance yang ingin Anda kelola.

4. Di panel navigasi sisi kiri, klik Topics.

5. Di halaman Topics, klik Create Topic.

6. Di panel Create Topic, tentukan properti topik dan klik OK.

   Parameter	Deskripsi	Contoh
   Name	Nama topik.	demo
   Description	Deskripsi topik.	demo test
   Partitions	Jumlah partisi dalam topik.	12
   Storage Engine Catatan Anda hanya dapat menentukan jenis mesin penyimpanan jika Anda menggunakan instance Edisi Profesional non-serverless. Untuk jenis instance lainnya, Cloud Storage dipilih secara default.	Jenis mesin penyimpanan yang digunakan untuk menyimpan pesan dalam topik. ApsaraMQ for Kafka mendukung jenis mesin penyimpanan berikut: Cloud Storage: Jika Anda memilih nilai ini, sistem menggunakan disk Alibaba Cloud untuk topik dan menyimpan data dalam tiga replika dalam mode terdistribusi. Mesin penyimpanan ini memiliki latensi rendah, performa tinggi, daya tahan panjang, dan keandalan tinggi. Jika Anda mengatur parameter Instance Edition ke Standard (High Write) saat Anda membuat instance, Anda hanya dapat mengatur parameter ini ke Cloud Storage. Local Storage: Jika Anda memilih nilai ini, sistem menggunakan algoritma in-sync replicas (ISR) dari Apache Kafka open source dan menyimpan data dalam tiga replika dalam mode terdistribusi.	Cloud Storage
   Message Type	Jenis pesan topik. Nilai valid: Normal Message: Secara default, pesan yang memiliki kunci yang sama disimpan di partisi yang sama sesuai urutan pengiriman pesan. Jika broker dalam kluster gagal, urutan pesan yang disimpan dalam partisi mungkin tidak dipertahankan. Jika Anda mengatur parameter Storage Engine ke Cloud Storage, parameter ini secara otomatis diatur ke Normal Message. Partitionally Ordered Message: Secara default, pesan yang memiliki kunci yang sama disimpan di partisi yang sama sesuai urutan pengiriman pesan. Jika broker dalam kluster gagal, pesan masih disimpan dalam partisi sesuai urutan pengiriman pesan. Pesan dalam beberapa partisi tidak dapat dikirim sampai partisi dipulihkan. Jika Anda mengatur parameter Storage Engine ke Local Storage, parameter ini secara otomatis diatur ke Partitionally Ordered Message.	Normal Message
   Log Cleanup Policy	Kebijakan pembersihan log yang digunakan oleh topik. Jika Anda mengatur parameter Storage Engine ke Local Storage, Anda harus mengonfigurasi parameter Log Cleanup Policy. Anda hanya dapat mengatur Parameter Mesin Penyimpanan ke Penyimpanan Lokal jika Anda menggunakan instance ApsaraMQ for Kafka Edisi Profesional. ApsaraMQ for Kafka menyediakan kebijakan pembersihan log berikut: Delete: kebijakan pembersihan log default. Jika ruang penyimpanan mencukupi, pesan akan disimpan hingga periode retensi maksimum tercapai. Saat penggunaan penyimpanan melebihi 85%, sistem akan menghapus pesan tertua untuk menjaga ketersediaan layanan. Compact: kebijakan pemadatan log yang digunakan di Apache Kafka. Pemadatan log memastikan bahwa nilai terbaru dipertahankan untuk pesan yang memiliki kunci yang sama. Kebijakan ini cocok untuk skenario seperti memulihkan sistem yang gagal atau memuat ulang cache setelah sistem di-restart. Misalnya, ketika Anda menggunakan Kafka Connect atau Confluent Schema Registry, Anda harus menyimpan informasi tentang status dan konfigurasi sistem di topik yang dipadatkan lognya. Penting Anda hanya dapat menggunakan topik yang dipadatkan lognya di komponen cloud-native tertentu, seperti Kafka Connect dan Confluent Schema Registry. Untuk informasi lebih lanjut, lihat aliware-kafka-demos.	Compact
   Tag	Tag yang ingin Anda lampirkan ke topik.	demo

   Setelah topik dibuat, Anda dapat melihatnya di halaman Topics.

Kirim pesan

Kirim pesan ke topik yang telah dibuat.

1. Pada halaman Topics, klik nama topik yang ingin Anda kelola. Di pojok kanan atas halaman Topic Details, klik tombol Send Message.Name

2. Di panel Start to Send and Consume Message, konfigurasikan parameter untuk mengirim pesan uji.

   • Jika Anda mengatur parameter Sending Method ke Console, lakukan langkah-langkah berikut:

     1. Di bidang Message Key, masukkan kunci pesan. Contoh: demo.

     2. Di bidang Message Content, masukkan isi pesan. Contoh: {"key": "test"}.

     3. Konfigurasikan parameter Send to Specified Partition untuk menentukan apakah akan mengirim pesan uji ke partisi tertentu.

        • Jika ingin mengirim pesan uji ke partisi tertentu, klik Yes dan masukkan ID partisi di bidang Partition ID. Contoh: 0. Untuk informasi tentang cara menanyakan ID partisi, lihat Lihat status partisi.

        • Jika tidak ingin mengirim pesan uji ke partisi tertentu, klik No.

     4. Gunakan SDK ApsaraMQ for Kafka atau jalankan perintah Docker yang ditampilkan di panel Mulai Mengirim dan Mengonsumsi Pesan untuk berlangganan pesan uji.

   • Jika Anda mengatur parameter Sending Method ke Docker, lakukan langkah-langkah berikut untuk menjalankan kontainer Docker:

     1. Jalankan perintah Docker yang ditampilkan di bagian Run the Docker container to produce a sample message untuk mengirim pesan uji.

     2. Jalankan perintah Docker yang ditampilkan di bagian How do I consume a message after the message is sent? untuk berlangganan pesan uji.

   • Jika Anda mengatur parameter Sending Method ke SDK, pilih SDK untuk bahasa pemrograman atau framework yang diperlukan serta metode akses untuk mengirim dan berlangganan pesan uji.

Lihat status partisi

Setelah mengirim pesan ke partisi tertentu, lihat status partisi.

Kueri pesan berdasarkan offset

1. Masuk ke konsol ApsaraMQ for Kafka.

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

3. Di halaman Instances, klik nama instance yang ingin Anda kelola.

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

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

6. Pilih topik dari daftar drop-down Topic dan partisi dari daftar drop-down Partition, masukkan nilai offset di bidang Offset, lalu klik Search.

   Pesan dengan nilai offset lebih besar dari atau sama dengan nilai offset yang ditentukan akan ditampilkan. Misalnya, jika Anda menentukan 5 sebagai nilai parameter Partisi dan Offset, sistem akan menanyakan pesan dengan offset sama dengan atau lebih besar dari 5 dari Partisi 5.

   Tabel 2. Parameter yang termasuk dalam hasil kueri pesan

   Parameter	Deskripsi
   Partition	Partisi tempat pesan diambil.
   Offset	Offset pesan.
   Key	Kunci pesan. Kunci dikonversi menjadi string.
   Value	Nilai pesan, yang juga dikenal sebagai isi pesan. Nilai pesan dikonversi menjadi string.
   Created At	Titik waktu ketika pesan dikirim. Nilainya adalah cap waktu yang direkam oleh klien ketika pesan dikirim atau nilai bidang timestamp yang Anda tentukan untuk objek ProducerRecord. Catatan Jika Anda menentukan nilai untuk bidang timestamp, nilai yang ditentukan akan ditampilkan. Jika Anda tidak menentukan nilai untuk bidang timestamp, waktu sistem ketika pesan dikirim akan ditampilkan. Nilai dalam format 1970/x/x x:x:x menunjukkan bahwa bidang timestamp ditentukan sebagai 0 atau nilai tidak valid. Anda tidak dapat menentukan bidang timestamp pada klien ApsaraMQ for Kafka versi 0.9 atau lebih awal.
   Actions	Klik Download Key untuk mengunduh kunci pesan. Klik Download Value untuk mengunduh isi pesan. Penting Hingga 1 KB konten untuk setiap pesan yang diambil dapat ditampilkan di konsol ApsaraMQ for Kafka. Jika pesan yang diambil melebihi 1 KB ukurannya, sistem secara otomatis memotong kontennya. Jika Anda ingin melihat isi pesan lengkap, unduh pesan tersebut. Anda dapat mengunduh hingga 10 MB pesan yang diambil sekaligus. Jika pesan yang diambil melebihi 10 MB ukurannya, hanya 10 MB pertama dari isi pesan yang dapat diunduh.