ApsaraMQ for Kafka：Bagaimana cara mengelola offset konsumen di konsol?

Mekanisme komisi offset konsumen

Offset konsumen tidak selalu dikomit setelah pesan dikonsumsi. Broker mencatat offset konsumen yang dikomit oleh konsumen.

Mekanisme pengiriman offset konsumen bervariasi tergantung pada SDK klien yang digunakan. Secara umum, mekanisme berikut didukung:

• Komisi Otomatis: SDK mengirim offset konsumen dari pesan terakhir yang dikonsumsi ditambah 1 pada interval tertentu.

• Komisi Manual: Anda memanggil fungsi commit(offsets) untuk mengirim offset konsumen dari pesan terakhir yang dikonsumsi ditambah 1 di sisi klien.

Prosedur

1. Lihat offset konsumen

   Pada tab Subscriptions halaman Topic Details, klik Consumer Details di kolom Actions topik yang ingin dikelola. Di panel yang muncul, lihat offset konsumen yang telah dikomit oleh konsumen yang relevan. Konsumen akan melanjutkan konsumsi dari offset ini. Untuk informasi lebih lanjut, lihat Lihat detail konsumen.

2. Setel ulang offset konsumen

   Di pojok kanan atas halaman Detail Grup, klik Reset Consumer Offset. Di panel Reset Consumer Offset, pilih metode untuk menyetel ulang offset konsumen. Untuk informasi lebih lanjut, lihat Setel ulang offset konsumen.

   Penting

   Sebelum menyetel ulang offset konsumen dari grup konsumen di konsol ApsaraMQ for Kafka, pastikan untuk menghentikan konsumen. Jika tidak, offset konsumen yang diperbarui dapat ditimpa oleh offset baru yang dikomit oleh konsumen.