Dus ik takeHead en dan begin ik met verwerken. Probleem als dit moet worden geschaald en met behulp van een 8-threads executor-service per pod/instantie, bij plotseling afsluiten van het systeem, zouden de "berichten" al als ontvangen / verbruikt zijn beschouwd.
U moet in plaats daarvan het RStream-object gebruiken om niet-geconsumeerde elementen per consument te volgen.