Also nehme ich Head und beginne mit der Verarbeitung. Problem, wenn dies skaliert werden soll und ein Executor-Dienst mit 8 Threads pro Pod/Instanz verwendet wird, würden die „Nachrichten“ beim plötzlichen Herunterfahren des Systems als bereits genommen/verbraucht gelten.
Sie müssen stattdessen das RStream-Objekt verwenden, das es ermöglicht, nicht verbrauchte Elemente pro Verbraucher zu verfolgen.
