apache-kafka

12गर्मी

4उत्तर

एक कफका विषय के प्रत्येक विभाजन में काम और ऑफसेट की संख्या

के प्रत्येक विभाजन में कफका विषय के प्रत्येक विभाजन में कमेट्स और वर्तमान ऑफसेट की संख्या कैसे प्राप्त करें। मैं काफ्का का उपयोग कर रहा v0.8.1.1

7गर्मी

2उत्तर

काफ्का उपभोक्ता सत्र समय

हमारे पास एक ऐसा एप्लिकेशन है जो उपभोक्ता एक संदेश पढ़ता है और धागा किसी अन्य विषय पर संदेश से पहले डेटाबेस पहुंच सहित कई चीजें करता है। धागे पर संदेश लेने और उत्पादन के बीच का समय कई मिनट लग सकता है।

9गर्मी

7उत्तर

स्पार्क स्ट्रीमिंग

में KafkaUtils क्लास नहीं मिला है मैंने अभी स्पार्क स्ट्रीमिंग के साथ शुरुआत की है और मैं एक नमूना एप्लिकेशन बनाने की कोशिश कर रहा हूं जो कफका धारा से शब्दों की गणना करता है। हालांकि यह sbt package के

7गर्मी

1उत्तर

काफ्का टॉपिक बनाम विभाजन विषय

मैं जानना चाहता हूं कि सरल विषय & विभाजन विषय के बीच क्या अंतर है। लोड को संतुलित करने के लिए मेरी समझ के अनुसार, विषय विभाजित किया गया है, प्रत्येक संदेश ऑफसेट होगा & उपभोक्ता पिछले सुनिश्चित करने के

5गर्मी

1उत्तर

जावा में काफ्का जेडस्ट्रिंगसेरियलाइज़र कैसे बनाएं?

कैसे एपीआई के माध्यम से एक काफ्का विषय बनाने के लिए के लिए खोज में, मैं स्काला में इस उदाहरण पाया: import kafka.admin.AdminUtils import kafka.utils.ZKStringSerializer import org.I0Itec.zkclient.ZkCl

7गर्मी

1उत्तर

काफ्का - सबसे आसान तरीका नवीनतम ऑफसेट हो जाओ करने के लिए

मैं एक आवेदन है कि सदस्यता काफ्का से विषय जोड़ और गतिशील रूप से हटाया जा करने की अनुमति देता का निर्माण कर रहा हूँ। जब एक विषय सदस्यता जोड़ा जाता है मैं एक बैच कार्य हर घंटे कि नए संदेशों के सब हो जात

24गर्मी

2उत्तर

काफ्का उपभोक्ता ज़ूकीपर से क्यों जुड़ते हैं, और निर्माता ब्रोकरों से मेटाडेटा प्राप्त करते हैं?

क्यों यह है कि उपभोक्ता विभाजन स्थानों को पुनर्प्राप्त करने के लिए ज़ूकीपर से कनेक्ट होते हैं? और कफका उत्पादकों को मेटाडेटा को पुनः प्राप्त करने के लिए ब्रोकरों में से एक से जुड़ना होगा। मेरा मुद्दा

8गर्मी

2उत्तर

काफ्का क्लस्टर आकार

कैसे तय करें मैं यह तय करने की योजना बना रहा हूं कि काफ्का क्लस्टर पर कितने नोड मौजूद होना चाहिए। मैं मानकों को ध्यान में रखना सुनिश्चित नहीं कर रहा हूं। मुझे यकीन है कि यह होना चाहिए> = 3 (2 के प्रति

5गर्मी

2उत्तर

काफ्का Zookeeper कनेक्शन जारी करता

मैं काफ्का 0.8.2 बीटा का उपयोग कर रहा है और 2 उबंटू 14 आभासी मशीनों: 172.30.141.127 Zookeeper 172.30.141.184 चल रहा है एक काफ्का दलाल चल रहा है मैं जुकीपर उदाहरण शुरू कर रहा हूं और सब ठीक है। फिर मैं

13गर्मी

3उत्तर

काफ्का - जावा

का उपयोग कर रिमोट सर्वर पर एक संदेश भेजने में असमर्थ मैं रिमोट कंट्रोल पर संदेश भेजने के लिए Kafka क्लस्टर बनाने की कोशिश कर रहा हूं। मैंने here वर्णित सब कुछ कॉन्फ़िगर किया है। मैं इसे Linux red hat