स्प्रिंग एमवीसी के साथ अपाचे काफ्का का उपयोग कैसे करें? क्या यह संभव है?

Question

मैं अपाचे काफ्का के साथ शुरुआत कर रहा हूं और संगठित सीखने की कोशिश कर रहा हूं - कफका - आराम - यूटिल, हालांकि मैं इस बात का भ्रमित कर रहा हूं कि मैं इसका उपयोग कैसे कर सकता हूं।

खोज के दौरान मैं इस दस्तावेज़ https://spring.io/blog/2015/04/15/using-apache-kafka-for-integration-and-data-processing-pipelines-with-spring

पाया यह बहुत अच्छा प्रलेखन है, लेकिन यह मुझे आराम-utils जानने के लिए मदद नहीं करता है।

संगामी काफ्का की Git कोड आराम utils

https://github.com/confluentinc/kafka-rest का प्रदर्शन कैसे आराम काफ्का उपयोग करने के लिए है। लेकिन मैं इसके बारे में अधिक जागरूक होने के लिए सटीक प्रक्रिया जानना चाहता हूं। कुछ सरल स्पष्टीकरण के साथ। क्या कोई मुझे कुछ क्लाइंट सुझा सकता है कि मैं बाकी क्लाइंट का उपयोग कैसे करता हूं। कृपया मुझे इसकी ओर निर्देशित करें।

यह एक मूर्ख सवाल हो सकता है लेकिन मेरे पास सीखने का दूसरा विकल्प नहीं है। पहले से

धन्यवाद।

Answer 1

सबसे पहले create a REST service using spring MVC को कफका सामान को अलग रखने की कोशिश करें।

एक बार जब आप में सक्षम रन बाकी सेवा का एक 'हैलो दुनिया' दयालु हैं, तो काफ्का डॉक्स लेने।

कफका क्लस्टर बनाने के तरीके पर दस्तावेज़ देखें और अपने क्लस्टर को जांचने के लिए डिफ़ॉल्ट कंसोल उपभोक्ता और निर्माता प्रोग्राम चलाएं।

अब, एक मुख्य जावा प्रोग्राम लिखें और Kafka Clients API का उपयोग करके एक कफका निर्माता बनाएं। अपने दस्तावेज़ों का संदर्भ लें। सुनिश्चित करें कि मुख्य कार्यक्रम के माध्यम से भेजे गए संदेश उपभोक्ता तक पहुंच रहे हैं।

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

उम्मीद है कि यह मदद करता है।