Deskripsi Masalah
Saat menggunakan klien Sarama Go, masalah berikut dapat terjadi:
Setelah menambahkan partisi ke sebuah topik, klien mungkin tidak mendeteksi partisi baru atau mengonsumsi pesan di dalamnya. Anda harus memulai ulang klien agar dapat mengonsumsi pesan dari partisi baru.
Banyak protokol klien Sarama Go tidak sesuai dengan standar komunitas Apache Kafka. Saat pengecualian terjadi pada broker, masalah berikut dapat muncul:
Mekanisme OutOfRange dapat dipicu di sisi klien. Jika kebijakan reset offset konsumen diatur ke
Oldest(earliest)di sisi klien, pesan akan dikonsumsi ulang dari offset paling awal.Klien mungkin tetap berada dalam status Rebalance.
Solusi
Disarankan untuk mengganti klien Sarama Go dengan klien Confluent Go sesegera mungkin.
Untuk informasi lebih lanjut tentang demo klien Confluent Go, lihat kafka-confluent-go-demo.
Jika Anda tidak dapat mengganti klien, lakukan langkah-langkah berikut:
Di lingkungan produksi, atur kebijakan reset offset konsumen ke
Newest(latest). Di lingkungan debugging atau lingkungan lain di mana pesan dapat dikonsumsi berulang kali, atur kebijakan reset offset konsumen keOldest(earliest).Jika sejumlah besar pesan terakumulasi karena reset offset konsumen, Anda dapat mereset offset konsumen ke offset pada titik waktu tertentu di konsol ApsaraMQ for Kafka. Dengan cara ini, Anda tidak perlu memodifikasi kode klien atau mengubah grup konsumen untuk mereset offset konsumen. Untuk informasi lebih lanjut, lihat Reset consumer offsets.