क्या एक विशिष्ट रिकॉर्ड के लिए कफका विषय से पूछने का कोई शानदार तरीका है? मैं जिस आरईएसटी एपीआई का निर्माण कर रहा हूं वह एक आईडी प्राप्त करता है और उसे एक कफका विषय में उस आईडी से जुड़े रिकॉर्ड देखने की आवश्यकता होती है। एक दृष्टिकोण कस्टम उपभोक्ता के माध्यम से विषय में हर रिकॉर्ड की जांच करना और एक मैच की तलाश करना है, लेकिन मैं रिकॉर्ड्स का एक समूह पढ़ने के ऊपरी हिस्से से बचना चाहता हूं। क्या कफका की तेज़ी से फ़िल्टरिंग क्षमता में बनाया गया है?विशिष्ट रिकॉर्ड के लिए क्वेरी काफ्का विषय
उत्तर
काफ्का (oversimplify करने के लिए) में एक रिकॉर्ड की खोज करने का एकमात्र तेज़ तरीका विभाजन और ऑफसेट द्वारा है। नया निर्माता वर्ग, वायदा, विभाजन और ऑफसेट के माध्यम से एक संदेश लिखा गया था, के माध्यम से वापस आ सकता है। संदेश को पुनः प्राप्त करने के लिए आप इन दो मानों का उपयोग कर सकते हैं।
तो यदि आप विभाजन और ऑफ़सेट से आईडी बनाते हैं तो आप अपनी तेज क्वेरी को कार्यान्वित कर सकते हैं। अन्यथा, इतना नहीं। इसका मतलब है कि किसी ऑब्जेक्ट के लिए आईडी आपके डेटा मॉडल का हिस्सा नहीं है, बल्कि कफका-ज्ञात कोड द्वारा उत्पन्न की जाती है।
शायद यह आपके लिए काम करता है, शायद यह नहीं करता है।
[विधि जो भविष्य लौटाती है] (https://kafka.apache.org/0101/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html#send (org.apache.kafka.clients.producer.ProducerRecord)) विभाजन और ऑफ़सेट – ruhong
यह आप के लिए देर से हो सकता है, लेकिन यह कैसे अन्य इस सवाल को देखने के लिए मदद मिलेगी, अब वहाँ KSQL है, काफ्का एसक्यूएल, एक खुला स्रोत स्ट्रीमिंग एसक्यूएल इंजन
AFAIK Kafka स्ट्रीम ब्रोकर पर नहीं, क्लाइंट-साइड फ़िल्टरिंग करता है। इस प्रकार आप अभी भी नेटवर्क पर सभी डेटा ला रहे हैं। –
हां, आप सही हैं @ सेर्गेईकोस्ट्रुकोव –
- 1. एक काफ्का विषय से दूसरे काफ्का विषय
- 2. भेजें कस्टम जावा काफ्का विषय
- 3. काफ्का टॉपिक बनाम विभाजन विषय
- 4. गैर डुप्लिकेट रिकॉर्ड के लिए SQL क्वेरी
- 5. sublimetext2 में परियोजना विशिष्ट विषय
- 6. विशिष्ट रिकॉर्ड मान प्राप्त करें
- 7. काफ्का स्ट्रीमिंग Concurrency?
- 8. विषय सारांश और छवि के लिए फ्रीबेस एमक्यूएल क्वेरी?
- 9. काफ्का संदेश
- 10. विशिष्ट क्वेरी
- 11. मैं जूनिट परीक्षणों के लिए नकली काफ्का विषय कैसे चालू कर सकता हूं?
- 12. LINQ क्वेरी शीर्ष रिकॉर्ड
- 13. काफ्का 0.9 - जावा एपीआई
- 14. काफ्का क्लस्टर
- 15. उपयोगकर्ता विशिष्ट रिकॉर्ड के लिए रेल एक्शन कैशिंग
- 16. mongodb विशिष्ट रिकॉर्ड प्राप्त करें
- 17. काफ्का स्ट्रीम एप्लिकेशन डिज़ाइन प्रिंसिपल
- 18. SQLite क्वेरी एक रिकॉर्ड सम्मिलित करने के लिए
- 19. मर्ज क्वेरी और हटाने रिकॉर्ड
- 20. XPath क्वेरी विशिष्ट पाठ
- 21. काफ्का उपभोक्ता सूची
- 22. काफ्का उपभोक्ता सत्र समय
- 23. रीसेट उपभोक्ता काफ्का 0.10
- 24. विशिष्ट उपयोगकर्ता द्वारा कल आइटम बदलने के लिए टीएफएस क्वेरी
- 25. विशिष्ट कॉलम प्राप्त करने के लिए हाइबरनेट मानदंड क्वेरी
- 26. कई मूल्य प्राप्त करने के लिए Django MySQL विशिष्ट क्वेरी
- 27. टीएफएस: एक विशिष्ट बदलाव युक्त निर्माण के लिए क्वेरी
- 28. काफ्का क्विकस्टार्ट, advertised.host.name kafka.common.LeaderNotAvailableException
- 29. काफ्का उपभोक्ता प्रमुख मूल्य जोड़ी
- 30. क्वेरी एक विशिष्ट चर के संरेखण
क्रिस बताते हैं के रूप में है कफका व्यक्तिगत रिकॉर्ड पुनर्प्राप्त करने के लिए कुछ तंत्र प्रदान करता है। लेकिन मुझे सावधानी बरतनी होगी कि ऐसा करना कफका मुख्य रूप से http://kafka.apache.org/documentation.html#uses के लिए डिज़ाइन नहीं किया गया है। यदि आप मुख्य रूप से किसी विषय से अलग-अलग संदेशों को पुनर्प्राप्त करने के लिए काफ्का का उपयोग कर रहे हैं, तो एक अलग सॉफ़्टवेयर का उपयोग करके आपके उपयोग के मामले में बेहतर फिट हो सकता है। – morganw09dev
हाँ, मैंने एक कफका उपभोक्ता को लागू करने का निर्णय लिया है जो मोंगो डेटाबेस को लिखता है, और फिर मेरा आरईएसटी एपीआई वहां से अलग-अलग रिकॉर्ड का अनुरोध कर सकता है। मैंने क्रिस के जवाब को वोट दिया क्योंकि इसने मेरे संदेह की पुष्टि की कि यह संभव नहीं था (कम से कम सुंदरता से)। – user554481