Así que tomo Head y luego empiezo a procesar. Problema si esto se va a escalar y usar un servicio de ejecución de 8 subprocesos por pod/instancia, en el apagado repentino del sistema, los "mensajes" ya se habrían considerado tomados/consumidos.
Debe usar el objeto RStream en su lugar, permite rastrear elementos no consumidos por consumidor.
