apache-kafka

17गर्मी

4उत्तर

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

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

6गर्मी

2उत्तर

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

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

5गर्मी

2उत्तर

आर

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

7गर्मी

3उत्तर

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

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

10गर्मी

3उत्तर

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

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

21गर्मी

5उत्तर

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

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

6गर्मी

2उत्तर

जावा कोड

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