Więc bioręHead wtedy zaczynam przetwarzanie. Problem, jeśli ma to być skalowane i przy użyciu 8-wątkowej usługi wykonawczej na pod/instancję, przy nagłym zamknięciu systemu, „wiadomości” zostałyby już uznane za zajęte/zużyte.
Zamiast tego musisz użyć obiektu RStream, który pozwala śledzić nieużywane elementy na konsumenta.
