मान लीजिए कि स्पार्क द्वारा दी गई 2 स्ट्रीमिंग और इनमें से एकस्ट्रीमिंग सिंक में 100% नहीं है। स्ट्रीमिंग करने में अंतर हो सकता है। हमें कुंजी द्वारा स्ट्रीमिंग में शामिल होने की आवश्यकता है। क्या कोई ऐसा तरीका है जिसे हम बिना किसी दृढ़ता के कर सकते हैं?
उत्तर:
जवाब के लिए 0 № 1मुझे नहीं लगता कि यह संभव है, काफ्का जलधाराएँएक निरंतर अद्यतन तालिका के रूप में एक काफ्का विषय में डेटा की व्याख्या करने के लिए अंतर्निहित समर्थन के साथ। कफका स्ट्रीम डीएसएल में यह तथाकथित के माध्यम से हासिल किया जाता है Ktable
इन KTables द्वारा समर्थित हैं राज्य के स्टोर कफका धाराओं में। ये राज्य भंडार आपके आवेदन के लिए स्थानीय हैं (अधिक सटीक: वे आपके आवेदन के उदाहरणों के लिए स्थानीय हैं, जिनमें से एक या कई हो सकते हैं), जिसका अर्थ है कि इन राज्य दुकानों के साथ बातचीत करने के लिए नेटवर्क पर बात करने की आवश्यकता नहीं है, इसलिए पढ़ें और लेखन कार्य बहुत तेज हैं। यह सुनिश्चित करने के लिए कि आपने डेटा को जारी नहीं रखने का फैसला किया है, आप जानकारी खोना शुरू कर सकते हैं जो आप नहीं चाहते हैं