Så jag tar huvudet och sedan börjar jag bearbeta. Problem om detta ska skalas och använda en 8-tråds exekveringstjänst per pod/instans, vid plötslig avstängning av systemet, skulle "meddelandena" redan ha ansetts vara tagna/konsumerade.
Du måste använda RStream-objekt istället för att spåra outnyttjade element per konsument.