Vì vậy, tôi takeHead rồi tôi bắt đầu xử lý. Vấn đề nếu điều này được chia tỷ lệ và sử dụng dịch vụ trình thực thi 8 luồng cho mỗi nhóm / phiên bản, khi hệ thống tắt đột ngột, các "thông báo" sẽ được coi là đã được sử dụng / sử dụng.
Bạn cần sử dụng đối tượng RStream để thay thế nó cho phép theo dõi các phần tử chưa tích lũy trên mỗi người tiêu dùng.
