Quindi prendo Head e poi inizio l'elaborazione. Problema se questo deve essere ridimensionato e utilizzando un servizio di esecuzione di 8 thread per pod/istanza, in caso di arresto improvviso del sistema, i "messaggi" sarebbero stati già considerati presi / consumati.
È necessario utilizzare l'oggetto RStream invece che consente di tenere traccia degli elementi non consumati per consumatore.
