मैं काफ्का के लिए पायथन उच्च स्तरीय उपभोक्ता का उपयोग कर रहा हूं और किसी विषय के प्रत्येक विभाजन के लिए नवीनतम ऑफ़सेट जानना चाहता हूं। हालांकि मैं इसे काम नहीं कर सकता। from kafka import TopicPartitio
मैं नीचे दिखाए गए अनुसार वाइल्डकार्ड वाले पैटर्न का उपयोग करके काफ्का की सदस्यता ले रहा हूं। वाइल्डकार्ड गतिशील ग्राहक आईडी का प्रतिनिधित्व करता है। consumer.subscribe(pattern='customer.*.validations'
का उपयोग कर कफका को बड़े सीएसवी भेजना मैं कफका को एक बड़ा सीएसवी भेजने की कोशिश कर रहा हूं। मूल संरचना सीएसवी की एक रेखा को पढ़ने और शीर्षलेख के साथ ज़िप करने के लिए है। a = dict(zip(header, line.spli