Redisson, antrian / dequeu yang berfungsi. Strategi pemrosesan pesan/elemen pada penanganan pesan yang tidak lengkap pada sistem/pod shutdown

Jadi saya takeHead lalu saya mulai memproses. Masalah jika ini akan diskalakan dan menggunakan layanan eksekutor 8 thread per pod/instance, pada saat sistem dimatikan secara tiba-tiba, "pesan" akan dianggap telah diambil / dikonsumsi.

Anda perlu menggunakan objek RStream sebagai gantinya memungkinkan untuk melacak elemen yang tidak dikonsumsi per konsumen.