Então eu pego a cabeça e começo a processar. Problema se isso for dimensionado e usando um serviço executor de 8 threads por pod/instância, no desligamento repentino do sistema, as "mensagens" já teriam sido consideradas tomadas / consumidas.
Você precisa usar o objeto RStream em vez disso, ele permite rastrear elementos não consumidos por consumidor.
