मेरे पास एक निर्माता है जो किसी विषय/विभाजन को संदेश लिखता है। ऑर्डरिंग को बनाए रखने के लिए, मैं एकल विभाजन के साथ जाना चाहता हूं और मैं चाहता हूं कि 12 उपभोक्ता इस एकल विभाजन से सभी संदेशों को पढ़ सकें (कोई उपभोक्ता समूह नहीं, सभी संदेश सभी उपभोक्ताओं को जाना चाहिए)। क्या यह प्राप्त करने योग्य है? मैंने कुछ मंच पढ़े हैं कि केवल एक उपभोक्ता प्रति विभाजन पढ़ सकता है।विभाजन के लिए काफ़का एकाधिक उपभोक्ता
उत्तर
आप जो भी पूछ रहे हैं उसे प्राप्त करने के लिए आप SimpleConsumer
का उपयोग कर सकते हैं - कोई उपभोक्ता समूह नहीं, सभी उपभोक्ता एक विभाजन पढ़ सकते हैं। हालांकि इस दृष्टिकोण का मतलब है कि आपको ऑफ़सेट स्टोरेज और ब्रोकर विफलता को संभालने में मदद करना है।
एक और विकल्प विभिन्न उपभोक्ता समूहों के साथ उच्च स्तर के उपभोक्ता का उपयोग करना है (आप केवल प्रत्येक उपभोक्ता को यादृच्छिक यूयूआईडी असाइन कर सकते हैं)। इस तरह आप सभी उपभोक्ताओं के साथ एक विषय/विभाजन का उपभोग करने में सक्षम होंगे और ऑफसेट करने और ब्रोकर आउटेज को संभालने में सक्षम होंगे।
नियम "केवल एक उपभोक्ता विषय/विभाजन का उपभोग कर सकता है" केवल उपभोक्ता समूहों पर लागू होता है, उदा। ग्रुप में केवल एक उपभोक्ता एक विषय/विभाजन को एक साथ उपभोग कर सकता है।
यदि आपके पास एक ही विभाजन पर एकाधिक उपभोक्ता हैं, तो यह आदेश जारी रखने की आपकी प्रारंभिक आवश्यकता को धड़कता है। हालांकि, आप भंडारण का आदेश दिया होगा, लेकिन खपत का आदेश नहीं दिया जाएगा। सुनिश्चित करें कि आप इसके साथ वास्तव में ठीक हैं। यदि हां, तो आप प्रत्येक उपभोक्ता को एक अलग उपभोक्ता समूह के रूप में देख सकते हैं।
- 1. मैं काफ़का में कई उपभोक्ताओं का उपयोग कैसे करूं?
- 2. एकाधिक उत्पादकों, एकल उपभोक्ता
- 3. कंडिट: एकाधिक स्ट्रीम उपभोक्ता
- 4. अवरुद्ध चयन एकाधिक उपभोक्ता
- 5. एकाधिक उत्पादक एकाधिक उपभोक्ता थ्रेड इश्यू
- 6. एकाधिक उपभोक्ता प्रति किनेसिस शर्ड
- 7. एकाधिक अवरुद्ध कतार, एकल उपभोक्ता
- 8. काफ्का: एकाधिक स्ट्रीम उपभोक्ता बनाएं
- 9. विभाजन एकाधिक फ़ाइलों
- 10. वसंत-एकीकरण-काफ्का कॉन्फ़िगरेशन उपभोक्ता निर्दिष्ट विभाजन से संदेश प्राप्त करने के लिए
- 11. एकाधिक उपभोक्ता और सी # ब्लॉकिंग कोलेक्शन
- 12. जावा -BlockingQueue - एकाधिक उत्पादकों, एकल उपभोक्ता
- 13. कफका उपभोक्ता ऑफसेट्स सीमा से बाहर विभाजन के लिए कोई कॉन्फ़िगर रीसेट नीति नहीं
- 14. जावा GAE के लिए ओपनआईडी उपभोक्ता
- 15. कैसे कफका विभाजन विभाजन को संतुलित करता है?
- 16. jQuery मोबाइल सूची पर एकाधिक विभाजन बटन
- 17. सीएसएस एकाधिक कॉलम लेआउट: गलत कॉलम विभाजन
- 18. अपाचे काफ्का उपभोक्ता समूह और सरल उपभोक्ता
- 19. क्या लॉकफ्री सेटिंग में एकाधिक-निर्माता, सिंगल-उपभोक्ता संभव है?
- 20. क्या डेल्फी के लिए लॉक-फ्री कतार "एकाधिक उत्पादक-एकल उपभोक्ता" मौजूद है?
- 21. उपभोक्ता ActiveMQ
- 22. ओरेकल विभाजन - त्रुटि ORA14400 - डाली गई विभाजन कुंजी किसी भी विभाजन के लिए मानचित्र नहीं है
- 23. ओएसजीआई सेवाएं वास्तुकला: उपभोक्ता
- 24. जीमेल एपीआई के लिए उपभोक्ता कुंजी और उपभोक्ता रहस्य कैसे प्राप्त करें?
- 25. सी # निर्माता/उपभोक्ता
- 26. एक समूह में कफका एकल उपभोक्ता विफलता
- 27. काफ्का टॉपिक बनाम विभाजन विषय
- 28. फास्ट बहुपद विभाजन के लिए एफएफटी डिवीजन
- 29. विभाजन तालिकाओं के लिए अंगूठे का नियम
- 30. डेटाबेस विभाजन के लिए इष्टतम आकार
यदि मैं प्रत्येक उपभोक्ताओं के लिए अद्वितीय उपभोक्ता समूह का उपयोग करता हूं, तो मैं प्रत्येक ग्राहक के लिए एकल संदेश से सभी संदेशों को पढ़ूंगा? यानी कोड में कुछ .. props.put ("group.id", KafkaProperties.groupId); – skumar
हां, यदि आपके पास एक विभाजन वाले विषय में 1000 संदेश हैं तो विभिन्न उपभोक्ता समूहों वाले सभी उपभोक्ता प्रत्येक 1000 संदेश पढ़ेंगे। – serejja
क्या आप दृष्टिकोण 1 (ऑफ़सेट ऑफसेट और ब्रोकर विफलता) के लिए कुछ उदाहरण दे सकते हैं और दृष्टिकोण 2 के लिए (प्रत्येक उपभोक्ता को रैंडो यूईई असाइन करें)? – skumar