Deskripsi masalah
Jika Anda menggunakan Message Queue for Apache Kafka dengan versi broker 0.10.2, Anda tetap akan menerima peringatan tentang akumulasi pesan dari grup konsumen meskipun grup konsumen tersebut telah dihapus.
Penyebab
Pada versi server Kafka sebelum 2.0, Kafka open-source tidak menyediakan OpenAPI untuk menghapus grup dan offset konsumen. Oleh karena itu, penghapusan grup konsumen hanya dilakukan secara logis melalui konsol, tanpa benar-benar menghapus informasi seperti offset konsumen. Peringatan akumulasi pesan dihasilkan berdasarkan offset konsumen yang masih ada, sehingga Anda tetap menerima peringatan tersebut.
Solusi
Untuk menghentikan penerimaan peringatan akumulasi pesan setelah menghapus grup konsumen, gunakan salah satu solusi berikut:
- Tingkatkan versi broker instance Message Queue for Apache Kafka ke 2.2.0 atau lebih baru. Buat grup konsumen baru dengan konfigurasi yang sama seperti grup yang dihapus, lalu hapus grup tersebut. Untuk detail tentang cara meningkatkan versi broker, lihat Tingkatkan versi instance.
- Nonaktifkan aturan peringatan untuk akumulasi pesan. Untuk informasi lebih lanjut tentang cara menonaktifkan aturan ini, lihat Pemantauan dan peringatan.
- Tunggu hingga offset konsumen kedaluwarsa. Setelah periode retensi offset konsumen berakhir, offset akan otomatis dihapus karena kedaluwarsa. Di Message Queue for Apache Kafka, offset konsumen disimpan dalam topik bawaan dan tidak dapat dihapus secara langsung. Jika offset konsumen tidak diperbarui setelah melewati periode retensi, offset akan dihapus secara otomatis. Untuk informasi lebih lanjut tentang cara mengonfigurasi periode retensi offset konsumen, lihat Ubah konfigurasi pesan.
Catatan
Catatan: Jika ada thread konsumen aktif dalam grup, offset konsumen tidak akan dihapus meskipun telah melewati periode retensi. Untuk informasi lebih lanjut, lihat Mengapa offset konsumen kedaluwarsa tetapi belum dihapus?.
- Buat grup baru dan atur ulang offset konsumen setiap partisi menjadi 0 melalui konsol. Untuk detail lebih lanjut, lihat Atur ulang offset konsumen.
Ruang lingkup aplikasi
- Message Queue for Apache Kafka