Jika konsumen berhenti mengonsumsi pesan karena suatu exception, periksa offset konsumen terakhir yang telah dikomit dan atur ulang jika diperlukan.
Cara kerja komit offset
Offset konsumen melacak posisi pesan berikutnya yang akan dibaca dari suatu partisi. Broker tidak memperbarui posisi ini secara otomatis, melainkan hanya mencatat offset yang secara eksplisit dikomit oleh konsumen.
Metode komit bergantung pada SDK client. Sebagian besar SDK mendukung dua metode:
| Method | Description |
|---|---|
| Auto-commit | SDK secara berkala melakukan commit offset dari message terakhir yang dikonsumsi ditambah 1. |
| Manual commit | Aplikasi Anda memanggil commit(offsets) untuk secara eksplisit melakukan commit offset dari message terakhir yang dikonsumsi ditambah 1. |
Saat konsumen dimulai ulang, ia melanjutkan dari offset terakhir yang telah dikomit. Mengetahui metode komit yang digunakan aplikasi Anda membantu mendiagnosis mengapa konsumen membaca ulang atau melewatkan pesan.
Lihat offset konsumen saat ini
Untuk memeriksa offset terakhir yang telah dikomit oleh konsumen:
Buka halaman Topic Details untuk topik target.
Pada tab Subscriptions, temukan topik target lalu klik Consumer Details di kolom Actions.
Pada panel yang muncul, tinjau offset konsumen yang telah dikomit. Konsumen akan melanjutkan dari offset ini.
Untuk langkah-langkah lengkap, lihat View consumer details.
Atur ulang offset konsumen
Hentikan semua konsumen dalam kelompok konsumen sebelum mengatur ulang offset. Jika ada konsumen yang masih berjalan, konsumen tersebut mungkin mengomit offset baru yang menimpa nilai hasil pengaturan ulang.
Untuk mengatur ulang offset konsumen:
Buka halaman Group Details untuk kelompok konsumen target.
Di pojok kanan atas, klik Reset Consumer Offset.
Pada panel Reset Consumer Offset, pilih metode pengaturan ulang dan konfigurasikan offset target.
Untuk daftar lengkap metode pengaturan ulang dan petunjuk detail, lihat Reset consumer offsets.