Alors je prends la tête puis je commence le traitement. Problème si cela doit être mis à l'échelle et en utilisant un service d'exécution à 8 threads par pod/instance, lors d'un arrêt soudain du système, les "messages" auraient déjà été considérés comme pris/consommés.
Vous devez utiliser l'objet RStream à la place, il permet de suivre les éléments non consommés par consommateur.
