नहीं। आप जेसन रिकॉर्ड में स्कीमा सक्षम कर सकते हैं। JDBC स्रोत उन्हें आपके लिए बना सकता है तालिका की जानकारी के आधार पर
value.converter=org.apache.kafka...JsonConverter
value.converter.schemas.enable=true
यदि आप स्कीमा रजिस्ट्री का उपयोग करना चाहते हैं, तो आपको kafkastore.bootstrap.servers का उपयोग करना चाहिए .काफ्का पते के साथ, जुकीपर नहीं। तो हटा दें kafkastore.connection.url
कृपया दस्तावेज़ पढ़ें सभी संपत्तियों की व्याख्या के लिए
कोई फर्क नहीं पड़ता। स्कीमा विषय तब बनता है जब रजिस्ट्री पहली बार शुरू होती है
हां (उपलब्ध जेवीएम हीप स्पेस की अनदेखी)। फिर, यह काफ्का कनेक्ट प्रलेखन में विस्तृत है।
स्टैंडअलोन मोड का उपयोग करते हुए, आप पहले कनेक्ट वर्कर कॉन्फ़िगरेशन पास करते हैं, फिर एक कमांड में N कनेक्टर गुण तक
वितरित मोड का उपयोग करके, आप काफ्का कनेक्ट रेस्ट एपीआई का उपयोग करते हैं
https://docs.confluence.io/current/connect/managing/configuring .html
सबसे पहले, यह स्क्लाइट के लिए है, मैसकल/पोस्टग्रेज नहीं। आपको क्विकस्टार्ट फ़ाइलों का उपयोग करने की आवश्यकता नहीं है, वे केवल संदर्भ के लिए हैं
फिर से, सभी गुण अच्छी तरह से प्रलेखित हैं
https://docs.confluence.io /current/connect/kafka-connect-jdbc/index.html#connect-jdbc
आप इसे कैसे डिबग कर सकते हैं, इसके बारे में अधिक जानकारी यहां दी गई है
https://www.confluence.io/ ब्लॉग/काफ्का-कनेक्ट-डीप-डाइव-जेडीबीसी-सोर्स-कनेक्टर/
जैसा कि पहले कहा गया है, मैं व्यक्तिगत रूप से जहां संभव हो वहां डेबेज़ियम/सीडीसी का उपयोग करने का सुझाव दूंगा
RDS Aurora के लिए Debezium Connector
