Apa yang harus dilakukan jika Anda masih menerima peringatan akumulasi pesan setelah menghapus Group - ApsaraMQ for Kafka

Permasalahan

Saat menggunakan Alibaba Cloud ApsaraMQ for Kafka, Anda menerima peringatan akumulasi pesan meskipun Group telah dihapus.

Kemungkinan penyebab

Anda mungkin menerima peringatan akumulasi pesan karena alasan berikut:

Pada versi server-side Kafka 0.10.2, Apache Kafka open source tidak menyediakan API Kafka untuk menghapus Group dan consumer offset. Penghapusan Group hanya menghilangkannya secara logis dari konsol, sedangkan informasi sebenarnya di sisi server—seperti consumer offset—tidak dihapus. Sistem peringatan memeriksa message offset sehingga peringatan terus muncul.
Setelah menghapus Group, thread konsumen mungkin tidak berhenti atau proses penyeimbangan ulang (rebalancing) tidak terjadi. Akibatnya, thread tersebut terus mengonsumsi pesan dan memicu peringatan akumulasi pesan.

Solusi

Untuk menghentikan peringatan akumulasi pesan setelah menghapus Group, lakukan langkah-langkah berikut:

Periksa versi server-side dan lakukan tindakan yang sesuai:
- Untuk versi 2.2.0 dan yang lebih baru, lakukan langkah berikut:
  - Jika Group tidak memiliki thread konsumen aktif, hapus Group secara langsung. Thread konsumen aktif adalah thread yang berlangganan pesan menggunakan metode `subscribe`. Jika peringatan masih muncul setelah penghapusan Group, periksa apakah masih ada thread konsumen yang melakukan commit consumer offset.
  - Pastikan Group tersebut ada, lalu hentikan semua thread konsumen. Di konsol, atur ulang consumer offset ke 0 untuk partisi tempat Anda ingin menghentikan pelacakan akumulasi pesan. Sistem kemudian akan berhenti melacak akumulasi pada partisi-partisi tersebut. Untuk informasi selengkapnya, lihat Reset consumer offsets.
- Untuk versi sebelum 2.2.0, lakukan salah satu langkah berikut:
  - Tunggu hingga offset kedaluwarsa. Offset akan kedaluwarsa setelah melewati periode retensi consumer offset yang dikonfigurasi. Anda tidak dapat menghapus consumer offset secara langsung karena versi Apache Kafka open source yang bersangkutan tidak menyediakan antarmuka untuk operasi ini. Offset akan dihapus secara otomatis jika tidak diperbarui dalam periode retensinya. Untuk informasi selengkapnya tentang cara mengonfigurasi periode retensi consumer offset, lihat Ubah konfigurasi pesan.
  - Jika Anda tidak dapat menunggu consumer offset kedaluwarsa, pastikan Group ada dan hentikan semua thread konsumen. Kemudian, di konsol, atur ulang consumer offset ke 0 untuk partisi tempat Anda ingin menghentikan pelacakan akumulasi pesan. Sistem kemudian akan berhenti melacak akumulasi pada partisi-partisi tersebut. Untuk informasi selengkapnya, lihat Reset consumer offsets.
  - Jika Group tidak memiliki thread konsumen aktif, upgrade versi server-side ke 2.2.0 atau yang lebih baru. Setelah itu, buat ulang Group tersebut dan hapus kembali. Untuk informasi selengkapnya tentang cara melakukan upgrade versi server-side, lihat Upgrade instance versions.
Catatan
Pada versi 2.2.0 dan yang lebih baru, selama Group memiliki setidaknya satu thread konsumen aktif, consumer offset-nya tidak akan dihapus meskipun telah melebihi periode retensi consumer offset. Untuk informasi selengkapnya, lihat Mengapa consumer offset tidak dihapus setelah kedaluwarsa?.
Jika langkah-langkah di atas tidak menyelesaikan masalah, Anda dapat menonaktifkan Pemantauan Peringatan untuk akumulasi pesan. Untuk informasi selengkapnya tentang cara menonaktifkan aturan peringatan akumulasi pesan, lihat Cloud Monitor.