तो मैं हेड लेता हूं फिर मैं प्रोसेसिंग शुरू करता हूं। समस्या अगर इसे स्केल किया जाना है और सिस्टम के अचानक बंद होने पर प्रति पॉड/इंस्टेंस 8 थ्रेड एक्ज़ीक्यूटर सेवा का उपयोग करना है, तो "संदेश" पहले से ही लिया/उपभोग किया गया माना जाएगा।
आपको RStream ऑब्जेक्ट का उपयोग करने की आवश्यकता है, इसके बजाय यह प्रति उपभोक्ता अप्रयुक्त तत्वों को ट्रैक करने की अनुमति देता है।
