2014-06-25 26 views
5

मेरी सेटअप में, मैं तीन प्रक्रियाओं (एक सेवा के 3 उदाहरण) काफ्का से उपभोग कर सकते हैं कि के साथ एक उपभोक्ता समूह है। जो मुझे खुशी हो रही है वह यह है कि पहला नोड सभी ट्रैफिक प्राप्त कर रहा है। यदि एक नोड मैन्युअल रूप से मारे जाते हैं, तो अगला नोड सभी काफ्का यातायात उठाता है, लेकिन अंतिम शेष नोड निष्क्रिय रहता है।काफ्का कंज्यूमर ग्रुप में केवल एक उपभोक्ता हो रही संदेश

व्यवहार वांछित है कि सभी संदेशों को उपभोक्ता समूह है, जो है मैं क्या सोचा होना चाहिए के भीतर सभी उदाहरणों भर में समान रूप से वितरित करने के लिए है। जैसा कि मैं समझता हूं, कफका का तरीका यह है कि यह उपभोक्ता समूह के सभी सदस्यों के बीच संदेशों को समान रूप से वितरित करना है। क्या मेरी समझ सही है? मैं यह निर्धारित करने की कोशिश कर रहा हूं कि ऐसा क्यों हो सकता है कि उपभोक्ता समूह का केवल एक सदस्य भाग्य के साथ सभी यातायात प्राप्त कर रहा है। कोई विचार/सुझाव?

उत्तर

3

आप विषय एक से अधिक विभाजन समानांतर में यह उपभोग करने के लिए सक्षम होने के लिए होना सुनिश्चित करने की जरूरत है। एक उपभोक्ता समूह में उपभोक्ता ब्रोकर से एक या अधिक आवंटित विभाजन प्राप्त करता है लेकिन एक ही समूह को एक ही समूह के भीतर कई उपभोक्ताओं में कभी साझा नहीं किया जाएगा जब तक कोई उपभोक्ता ऑफ़लाइन न हो जाए। एक विषय के विभाजन की संख्या उपभोक्ता समूह में उपभोक्ताओं की अधिकतम संख्या के बराबर होती है जो किसी विषय से फ़ीड कर सकती हैं।

+0

इसलिए प्रत्येक उपभोक्ता के पास 4 धागे होते हैं और हमारे विषय में बारह विभाजन होते हैं, इसलिए प्रति विभाजन धागा होता है। – joshuaegclark

+0

विभाजन 10000 सेट करना बुरा है? यदि आप उपभोक्ताओं की मात्रा नहीं जानते हैं? – Spidfire

+0

विभाजन समन्वय वर्तमान में जुकीपर के माध्यम से किया जाता है और परिणामस्वरूप अधिक संख्या में विभाजन आपके उपभोक्ता के धीमी पुन: संतुलन के साथ आपके ज़ुकीपर के संगमरमर पर अधिक दबाव डाल देगा। एक और संभावित मुद्दा जो आप कई विभाजनों के साथ भाग सकते हैं, ब्रोकरों पर फाइल हैंडल की संख्या है। – Lundahl

संबंधित मुद्दे