apache-kafka

21गर्मी

5उत्तर

एवरो बाइनरी एन्कोडर का उपयोग करके कफका संदेशों को एन्कोड/डीकोड कैसे करें?

मैं कफका से पढ़ने/लिखे संदेशों के लिए एवरो का उपयोग करने की कोशिश कर रहा हूं। क्या किसी के पास एवरो बाइनरी एन्कोडर का उपयोग करने का एक उदाहरण है जो संदेश कतार में डाला जाएगा डेटा को एन्कोड/डीकोड करने

5गर्मी

1उत्तर

कफका में दलालों पर विभाजन पुन: संतुलन 0.8

काफ्का 0.8 के लिए अपेक्षाकृत दुर्लभ दस्तावेज का उल्लेख नहीं है कि ब्रोकरों पर मौजूदा विषयों, विभाजन और प्रतिकृतियों को संतुलित करने के लिए अपेक्षित व्यवहार क्या है। अधिक विशेष रूप से, ब्रोकर के आगमन औ

17गर्मी

4उत्तर

क्या काफ्का उत्पादन के उपयोग के लिए तैयार है?

मेरे पास उत्पादन में एक आवेदन है जिसे प्रति दिन कई गीगाबाइट संदेशों को संसाधित करना पड़ता है। मुझे काफ्का वास्तुकला और प्रदर्शन बहुत पसंद है; यह पूरी तरह से मेरी जरूरतों के अनुरूप फिट बैठता है। मैं कु

5गर्मी

2उत्तर

काफ्का स्कोउट का उपयोग कर काफ्का तूफान एकीकरण

मैं काफ्कास्पॉट का उपयोग कर रहा हूं। कृपया नीचे परीक्षण कार्यक्रम खोजें। मैं तूफान 0.8.1 का उपयोग कर रहा हूं। तूफान 0.8.2 में मल्टीशेम वर्ग है। मैं इसका इस्तेमाल करूँगा। मैं सिर्फ यह जानना चाहता हूं क

6गर्मी

2उत्तर

एक वस्तु का काफ्का सीरियलाइजेशन

मैंने कफका के साथ खेलना शुरू कर दिया। मैंने एक ज़ूकीपर कॉन्फ़िगरेशन सेट किया है, और मैं स्ट्रिंग संदेशों को भेजने और उपभोग करने में कामयाब रहा हूं। अब मैं ऑब्जेक्ट (जावा में) पास करने की कोशिश कर रहा

5गर्मी

2उत्तर

आर

में काफ्का उपभोक्ता मैं पाइथन या आर (अधिमानतः आर) में एक कफका उपभोक्ता को एक साथ हैक करना चाहता हूं। कर सकते हैं काफ्का सांत्वना उपभोक्ता का उपयोग करना मैं एक स्ट्रिंग के लिए grep और प्रासंगिक डेटा पु

7गर्मी

3उत्तर

अपाचे काफ्का: उपभोक्ता राज्य

मैंने कफका वेबसाइट पर प्रलेखन पढ़ा लेकिन पूर्ण न्यूनतम उदाहरण (निर्माता -> कफका -> उपभोक्ता) को लागू करने की कोशिश करने के बाद यह मुझे स्पष्ट नहीं है कि "उपभोक्ता राज्य", ऑफसेट को संभालने की जरूरत है।

10गर्मी

3उत्तर

स्थायी रूप से कफका सर्वर शुरू करना

मैंने अमेज़ॅन ईसी 2 उदाहरण पर कफका स्थापित किया है। मैं आदेश नीचे में निम्नलिखित किया है: उदाहरण में (1) SSH (2) प्रारंभ Zookeper (3) प्रारंभ काफ्का (4) निष्पादित उत्पादक और उपभोक्ता कार्यक्रम। सबकुछ

6गर्मी

2उत्तर

जावा कोड

का उपयोग कर तूफान टोपोलॉजी असंतुलन मैं अपने तूफान टोपोलॉजी को पुनर्व्यवस्थित करने की कोशिश कर रहा हूं जो एक काफ्कास्पॉट का उपयोग कर रहा है। मेरे कोड है: TopologyBuilder builder = new TopologyBuilder()