डेटा का मूल्य समय के प्रति संवेदनशील है। रीयल-टाइम प्रोसेसिंग डेटा-संचालित निर्णयों को घंटे या दिनों के बजाय सेकंड या मिनट में सटीक और कार्रवाई योग्य बनाता है। डेटा कैप्चर बदलें (सीडीसी) डेटाबेस में डेटा में किए गए परिवर्तनों को पहचानने और कैप्चर करने की प्रक्रिया को संदर्भित करता है और फिर उन परिवर्तनों को वास्तविक समय में डाउनस्ट्रीम सिस्टम में वितरित करता है। एक स्रोत डेटाबेस में लेन-देन से हर परिवर्तन को कैप्चर करना और उन्हें वास्तविक समय में लक्ष्य तक ले जाना सिस्टम को सिंक्रनाइज़ करता है, और रीयल-टाइम एनालिटिक्स उपयोग के मामलों और शून्य-डाउनटाइम डेटाबेस माइग्रेशन में मदद करता है। सीडीसी के कुछ लाभ निम्नलिखित हैं:
- यह आपके लक्ष्य रिपॉजिटरी में वृद्धिशील लोडिंग या डेटा परिवर्तनों की रीयल-टाइम स्ट्रीमिंग को सक्षम करके बल्क लोड अपडेटिंग और असुविधाजनक बैच विंडो की आवश्यकता को समाप्त करता है।
- यह सुनिश्चित करता है कि कई प्रणालियों में डेटा सिंक में रहता है। यह विशेष रूप से महत्वपूर्ण है यदि आप उच्च-वेग वाले डेटा वातावरण में समय-संवेदी निर्णय ले रहे हैं।
काफ्का कनेक्ट अपाचे काफ्का का एक ओपन-सोर्स घटक है जो डेटाबेस, की-वैल्यू स्टोर्स, सर्च इंडेक्स और फाइल सिस्टम के बीच सरल डेटा एकीकरण के लिए एक केंद्रीकृत डेटा हब के रूप में काम करता है। एडब्ल्यूएस गोंद स्कीमा रजिस्ट्री आपको डेटा स्ट्रीम स्कीमा को केंद्रीय रूप से खोजने, नियंत्रित करने और विकसित करने की अनुमति देता है। काफ्का कनेक्ट और स्कीमा रजिस्ट्री कनेक्टर्स से स्कीमा जानकारी प्राप्त करने के लिए एकीकृत होती हैं। काफ्का कनेक्ट, काफ्का कनेक्ट द्वारा उपयोग किए जाने वाले आंतरिक डेटा प्रकारों से डेटा को एवरो, प्रोटोबॉफ़ या JSON स्कीमा के रूप में दर्शाए गए डेटा प्रकारों में परिवर्तित करने के लिए एक तंत्र प्रदान करता है। AvroConverter, ProtobufConverter, और JsonSchemaConverter स्वचालित रूप से काफ्का कनेक्टर्स (स्रोत) द्वारा उत्पन्न स्कीमा पंजीकृत करते हैं जो काफ्का को डेटा उत्पन्न करते हैं। कनेक्टर्स (सिंक) जो काफ्का से डेटा का उपभोग करते हैं, प्रत्येक संदेश के डेटा के अलावा स्कीमा जानकारी प्राप्त करते हैं। यह सिंक कनेक्टर्स को डेटा कैटलॉग में डेटाबेस टेबल स्कीमा को बनाए रखने जैसी क्षमता प्रदान करने के लिए डेटा की संरचना को जानने की अनुमति देता है।
पोस्ट दर्शाती है कि कैसे एक एंड-टू-एंड सीडीसी का उपयोग करके बनाया जाए अमेज़न एमएसके कनेक्टकाफ्का कनेक्ट एप्लिकेशन और एडब्ल्यूएस ग्लू स्कीमा रजिस्ट्री को तैनात करने और चलाने के लिए एक एडब्ल्यूएस प्रबंधित सेवा, जो आपको डेटा स्ट्रीम स्कीमा को केंद्रीय रूप से खोजने, नियंत्रित करने और विकसित करने की अनुमति देती है।
समाधान अवलोकन
निर्माता पक्ष पर, इस उदाहरण के लिए हम एक MySQL-संगत चुनते हैं अमेज़न अरोड़ा डेटाबेस डेटा स्रोत के रूप में, और हमारे पास a डेबेज़ियम CDC करने के लिए MySQL कनेक्टर। Debezium कनेक्टर लगातार डेटाबेस पर नज़र रखता है और काफ्का विषय में पंक्ति-स्तर के बदलावों को आगे बढ़ाता है। कनेक्टर रिकॉर्ड को बाइनरी रूप में क्रमबद्ध करने के लिए डेटाबेस से स्कीमा प्राप्त करता है। स्कीमा पहले से ही रजिस्ट्री में मौजूद नहीं है, तो स्कीमा पंजीकृत किया जाएगा। यदि स्कीमा मौजूद है, लेकिन सीरिएलाइज़र एक नए संस्करण का उपयोग कर रहा है, तो स्कीमा रजिस्ट्री जाँच करती है संगतता मोड स्कीमा को अपडेट करने से पहले स्कीमा का। इस समाधान में हम उपयोग करते हैं पिछड़ा संगतता मोड. यदि स्कीमा का नया संस्करण पिछड़ा संगत नहीं है, तो स्कीमा रजिस्ट्री एक त्रुटि लौटाती है, और हम काफ्का कनेक्ट को मृत-पत्र कतार में असंगत संदेश भेजने के लिए कॉन्फ़िगर कर सकते हैं।
उपभोक्ता पक्ष पर, हम एक का उपयोग करते हैं अमेज़न सरल भंडारण सेवा (Amazon S3) सिंक कनेक्टर को रिकॉर्ड को डिसेर्बलाइज़ करने और Amazon S3 में परिवर्तनों को स्टोर करने के लिए। हम MSK Connect का उपयोग करके Debezium कनेक्टर और Amazon S3 सिंक का निर्माण और परिनियोजन करते हैं।
उदाहरण स्कीमा
इस पोस्ट के लिए, हम तालिका के पहले संस्करण के रूप में निम्न स्कीमा का उपयोग करते हैं:
.. पूर्वापेक्षाएँ
MSK निर्माता और उपभोक्ता कनेक्टर्स को कॉन्फ़िगर करने से पहले, हमें पहले एक डेटा स्रोत, MSK क्लस्टर और नई स्कीमा रजिस्ट्री सेट अप करने की आवश्यकता होती है। हम एक प्रदान करते हैं एडब्ल्यूएस CloudFormation समाधान के लिए आवश्यक सहायक संसाधन उत्पन्न करने के लिए टेम्पलेट:
- डेटा स्रोत के रूप में एक MySQL- संगत Aurora डेटाबेस। सीडीसी करने के लिए, हम बाइनरी लॉगिंग चालू करते हैं DB क्लस्टर पैरामीटर समूह.
- एक MSK क्लस्टर। नेटवर्क कनेक्शन को सरल बनाने के लिए, हम Aurora डेटाबेस और MSK क्लस्टर के लिए समान VPC का उपयोग करते हैं।
- संदेश कुंजी और संदेश मान के लिए स्कीमा को संभालने के लिए दो स्कीमा रजिस्ट्रियां।
- डेटा सिंक के रूप में एक S3 बाल्टी।
- इस डेमो के लिए आवश्यक एमएसके कनेक्ट प्लगइन्स और वर्कर कॉन्फ़िगरेशन।
- एक अमेज़ॅन इलास्टिक कम्प्यूट क्लाउड (Amazon EC2) उदाहरण डेटाबेस कमांड चलाने के लिए।
अपने एडब्ल्यूएस खाते में संसाधन स्थापित करने के लिए, अमेज़ॅन एमएसके, एमएसके कनेक्ट और एडब्ल्यूएस गोंद स्कीमा रजिस्ट्री का समर्थन करने वाले एडब्ल्यूएस क्षेत्र में निम्नलिखित चरणों को पूरा करें:
- चुनें स्टैक लॉन्च करें:
- चुनें अगला.
- के लिए ढेर का नाम, उपयुक्त नाम दर्ज करें।
- के लिए डेटाबेस पासवर्ड, वह पासवर्ड दर्ज करें जो आप डेटाबेस उपयोगकर्ता के लिए चाहते हैं।
- अन्य मानों को डिफ़ॉल्ट के रूप में रखें।
- चुनें अगला.
- अगले पेज पर, चुनें अगला.
- अंतिम पृष्ठ पर विवरण की समीक्षा करें और चुनें मैं स्वीकार करता हूं कि AWS CloudFormation IAM संसाधन बना सकता है.
- चुनें स्टैक बनाएँ.
स्रोत और गंतव्य कनेक्टर के लिए कस्टम प्लगइन
एक कस्टम प्लगइन JAR फ़ाइलों का एक सेट है जिसमें एक या अधिक कनेक्टर्स, ट्रांसफ़ॉर्म या कन्वर्टर्स का कार्यान्वयन होता है। अमेज़ॅन एमएसके एमएसके कनेक्ट क्लस्टर के श्रमिकों पर प्लगइन स्थापित करेगा जहां कनेक्टर चल रहा है। इस डेमो के भाग के रूप में, स्रोत कनेक्टर के लिए हम ओपन-सोर्स का उपयोग करते हैं Debezium MySQL कनेक्टर जार, और डेस्टिनेशन कनेक्टर के लिए हम लाइसेंस प्राप्त कंफ्लुएंट कम्युनिटी का उपयोग करते हैं अमेज़न S3 सिंक कनेक्टर जार. दोनों प्लगइन्स को लाइब्रेरी के साथ भी जोड़ा जाता है एवरो सीरियलाइज़र और डेसेरियलाइज़र एडब्ल्यूएस गोंद स्कीमा रजिस्ट्री की। ये कस्टम प्लगइन्स पहले से ही पिछले चरण में तैनात क्लाउडफॉर्मेशन टेम्पलेट के हिस्से के रूप में बनाए गए हैं।
MSK निर्माता के रूप में MSK कनेक्ट पर Debezium कनेक्टर के साथ AWS ग्लू स्कीमा रजिस्ट्री का उपयोग करें
हम पहले डेटा स्ट्रीम करने के लिए Debezium MySQL प्लगइन का उपयोग करके स्रोत कनेक्टर को तैनात करते हैं Amazon Aurora MySQL-संगत संस्करण Amazon MSK के लिए डेटाबेस। निम्नलिखित चरणों को पूरा करें:
- अमेज़ॅन एमएसके कंसोल पर, नेविगेशन फलक में, के तहत एमएसके कनेक्ट, चुनें कनेक्टर्स.
- चुनें कनेक्टर बनाएँ.
- चुनें मौजूदा कस्टम प्लगइन का प्रयोग करें और फिर कस्टम प्लगइन चुनें जिसका नाम शुरू हो रहा है
msk-blog-debezium-source-plugin
. - चुनें अगला.
- एक उपयुक्त नाम दर्ज करें जैसे
debezium-mysql-connector
और एक वैकल्पिक विवरण। - के लिए अपाचे काफ्का क्लस्टर, चुनें एमएसके क्लस्टर और CloudFormation टेम्प्लेट द्वारा बनाए गए क्लस्टर को चुनें।
- In कनेक्टर कॉन्फ़िगरेशन, डिफ़ॉल्ट मानों को हटाएं और निम्न कॉन्फ़िगरेशन कुंजी-मान जोड़े और उपयुक्त मानों का उपयोग करें:
- नाम - कनेक्टर के लिए प्रयुक्त नाम।
- डेटाबेस.होस्टनाम - के लिए CloudFormation आउटपुट डाटाबेस एंडपॉइंट.
- डेटाबेस.उपयोगकर्ता और डेटाबेस.पासवर्ड - CloudFormation टेम्प्लेट में पास किए गए पैरामीटर।
- डेटाबेस.history.kafka.bootstrap.servers - के लिए CloudFormation आउटपुट काफ्का बूटस्ट्रैप.
- key.converter.region और value.converter.region - आपका क्षेत्र।
इनमें से कुछ सेटिंग्स सामान्य हैं और किसी भी कनेक्टर के लिए निर्दिष्ट की जानी चाहिए। उदाहरण के लिए:
- कनेक्टर.क्लास कनेक्टर का जावा वर्ग है
- कार्य.मैक्स इस कनेक्टर के लिए बनाए जाने वाले कार्यों की अधिकतम संख्या है
कुछ सेटिंग (database.*
, transforms.*
) Debezium MySQL कनेक्टर के लिए विशिष्ट हैं। को देखें Debezium MySQL स्रोत कनेक्टर कॉन्फ़िगरेशन गुण देखें।
कुछ सेटिंग (key.converter.*
और value.converter.*
) स्कीमा रजिस्ट्री के लिए विशिष्ट हैं। हम उपयोग करते हैं AWSKafkaAvroConverter
से एडब्ल्यूएस गोंद स्कीमा रजिस्ट्री लाइब्रेरी प्रारूप परिवर्तक के रूप में। कॉन्फिगर करना AWSKafkaAvroConverter
, हम स्ट्रिंग स्थिर गुणों के मान का उपयोग करते हैं AWSSchemaRegistryConstants वर्ग:
key.converter
औरvalue.converter
स्रोत कनेक्टर्स के लिए काफ्का को लिखे जाने वाले डेटा के प्रारूप को नियंत्रित करें या सिंक कनेक्टर्स के लिए काफ्का से पढ़ें। हम उपयोग करते हैंAWSKafkaAvroConverter
एवरो प्रारूप के लिए।key.converter.registry.name
औरvalue.converter.registry.name
परिभाषित करें कि किस स्कीमा रजिस्ट्री का उपयोग करना है।key.converter.compatibility
औरvalue.converter.compatibility
संगतता मॉडल को परिभाषित करें।
का संदर्भ लें एडब्ल्यूएस गोंद स्कीमा रजिस्ट्री के साथ काफ्का कनेक्ट का उपयोग करना देखें।
- अगला, हम कॉन्फ़िगर करते हैं कनेक्टर क्षमता. हम चुन सकते हैं प्रावधान किए गए और अन्य गुणों को डिफ़ॉल्ट के रूप में छोड़ दें
- के लिए कार्यकर्ता विन्यास, आरंभिक नाम के साथ कस्टम वर्कर कॉन्फ़िगरेशन चुनें
msk-gsr-blog
CloudFormation टेम्प्लेट के हिस्से के रूप में बनाया गया। - के लिए पहुंच की अनुमति, उपयोग AWS पहचान और अभिगम प्रबंधन (आईएएम) क्लाउडफॉर्मेशन टेम्पलेट द्वारा उत्पन्न भूमिका
MSKConnectRole
. - चुनें अगला.
- के लिए सुरक्षा, डिफ़ॉल्ट चुनें।
- चुनें अगला.
- के लिए लॉग डिलीवरी, चुनते हैं Amazon CloudWatch लॉग्स को डिलीवर करें और CloudFormation टेम्प्लेट द्वारा बनाए गए लॉग समूह के लिए ब्राउज़ करें (
msk-connector-logs
). - चुनें अगला.
- सेटिंग्स की समीक्षा करें और चुनें कनेक्टर बनाएँ.
कुछ मिनटों के बाद, कनेक्टर चालू स्थिति में बदल जाता है।
MSK उपभोक्ता के रूप में MSK Connect पर चलने वाले कंफ्लुएंट S3 सिंक कनेक्टर के साथ AWS ग्लू स्कीमा रजिस्ट्री का उपयोग करें
हम Amazon MSK से Amazon S3 में डेटा स्ट्रीम करने के लिए Confluent S3 सिंक प्लगइन का उपयोग करके सिंक कनेक्टर को परिनियोजित करते हैं। निम्नलिखित चरणों को पूरा करें:
-
- अमेज़ॅन एमएसके कंसोल पर, नेविगेशन फलक में, के तहत एमएसके कनेक्ट, चुनें कनेक्टर्स.
- चुनें कनेक्टर बनाएँ.
- चुनें मौजूदा कस्टम प्लगइन का प्रयोग करें और शुरू होने वाले नाम के साथ कस्टम प्लगइन चुनें
msk-blog-S3sink-plugin
. - चुनें अगला.
- एक उपयुक्त नाम दर्ज करें जैसे
s3-sink-connector
और एक वैकल्पिक विवरण। - के लिए अपाचे काफ्का क्लस्टर, चुनें एमएसके क्लस्टर और CloudFormation टेम्प्लेट द्वारा बनाए गए क्लस्टर का चयन करें।
- In कनेक्टर कॉन्फ़िगरेशन, प्रदान किए गए डिफ़ॉल्ट मानों को हटा दें और उपयुक्त मानों के साथ निम्न कॉन्फ़िगरेशन कुंजी-मान युग्मों का उपयोग करें:
-
- नाम - कनेक्टर के लिए समान नाम का उपयोग किया जाता है।
- s3.बाल्टी.नाम - के लिए CloudFormation आउटपुट बकेट नाम.
- s3.region, key.converter.region, और value.converter.region - आपका क्षेत्र।
-
- अगला, हम कॉन्फ़िगर करते हैं कनेक्टर क्षमता. हम चुन सकते हैं प्रावधान किए गए और अन्य गुणों को डिफ़ॉल्ट के रूप में छोड़ दें
- के लिए कार्यकर्ता विन्यास, आरंभिक नाम के साथ कस्टम वर्कर कॉन्फ़िगरेशन चुनें
msk-gsr-blog
CloudFormation टेम्प्लेट के हिस्से के रूप में बनाया गया। - के लिए पहुंच की अनुमति, CloudFormation टेम्प्लेट द्वारा उत्पन्न IAM भूमिका का उपयोग करें
MSKConnectRole
. - चुनें अगला.
- के लिए सुरक्षा, डिफ़ॉल्ट चुनें।
- चुनें अगला.
- के लिए लॉग डिलीवरी, चुनते हैं Amazon CloudWatch लॉग्स को डिलीवर करें और CloudFormation टेम्प्लेट द्वारा बनाए गए लॉग समूह को ब्राउज़ करें
msk-connector-logs
. - चुनें अगला.
- सेटिंग्स की समीक्षा करें और चुनें कनेक्टर बनाएँ.
कुछ मिनटों के बाद, कनेक्टर चल रहा है।
संपूर्ण CDC लॉग स्ट्रीम का परीक्षण करें
अब जब दोनों Debezium और S3 सिंक कनेक्टर काम कर रहे हैं, तो एंड-टू-एंड सीडीसी का परीक्षण करने के लिए निम्नलिखित चरणों को पूरा करें:
- Amazon EC2 कंसोल पर, नेविगेट करें सुरक्षा समूह इस पृष्ठ पर ज़ूम कई वीडियो ट्यूटोरियल और अन्य साहायक साधन प्रदान करता है।
- सुरक्षा समूह का चयन करें
ClientInstanceSecurityGroup
और चुनें इनबाउंड नियम संपादित करें. - अपने स्थानीय नेटवर्क से SSH कनेक्शन की अनुमति देने वाला एक इनबाउंड नियम जोड़ें।
- पर उदाहरण पृष्ठ, उदाहरण का चयन करें
ClientInstance
और चुनें जुडिये. - पर EC2 इंस्टेंस कनेक्ट टैब चुनें जुडिये.
- सुनिश्चित करें कि आपकी वर्तमान कार्यशील निर्देशिका है
/home/ec2-user
और इसमें फाइलें हैंcreate_table.sql
,alter_table.sql
,initial_insert.sql
, तथाinsert_data_with_new_column.sql
. - निम्न आदेश चलाकर अपने MySQL डेटाबेस में एक टेबल बनाएं (CloudFormation टेम्पलेट आउटपुट से डेटाबेस होस्ट नाम प्रदान करें):
- जब पासवर्ड के लिए कहा जाए, तो CloudFormation टेम्प्लेट पैरामीटर से पासवर्ड दर्ज करें।
- निम्नलिखित आदेश के साथ तालिका में कुछ नमूना डेटा डालें:
- जब पासवर्ड के लिए कहा जाए, तो CloudFormation टेम्प्लेट पैरामीटर से पासवर्ड दर्ज करें।
- एडब्ल्यूएस गोंद कंसोल पर, चुनें स्कीमा रजिस्ट्रियां नेविगेशन फलक में, फिर चुनें स्कीमा.
- पर जाए
db1.sampledatabase.movies
चलचित्र तालिका के लिए बनाई गई नई स्कीमा की जाँच करने के लिए संस्करण 1:
काफ्का विषय के प्रत्येक विभाजन के लिए एक अलग S3 फ़ोल्डर बनाया जाता है, और उस फ़ोल्डर में विषय के लिए डेटा लिखा जाता है।
- Amazon S3 कंसोल पर, अपने काफ्का विषय के फ़ोल्डर में Parquet प्रारूप में लिखे गए डेटा की जाँच करें।
स्कीमा विकास
प्रारंभिक स्कीमा परिभाषित होने के बाद, अनुप्रयोगों को समय के साथ इसे विकसित करने की आवश्यकता हो सकती है। जब ऐसा होता है, तो डाउनस्ट्रीम उपभोक्ताओं के लिए पुराने और नए स्कीमा दोनों के साथ एन्कोड किए गए डेटा को सहजता से संभालने में सक्षम होना महत्वपूर्ण है। संगतता मोड आपको यह नियंत्रित करने की अनुमति देते हैं कि समय के साथ स्कीमा कैसे विकसित हो सकते हैं या नहीं। ये मोड डेटा बनाने और उपभोग करने वाले अनुप्रयोगों के बीच अनुबंध बनाते हैं। एडब्ल्यूएस ग्लू स्कीमा रजिस्ट्री में उपलब्ध विभिन्न अनुकूलता मोड के बारे में विस्तृत जानकारी के लिए देखें एडब्ल्यूएस गोंद स्कीमा रजिस्ट्री. हमारे उदाहरण में, हम यह सुनिश्चित करने के लिए बैकवर्ड कॉम्बेबिलिटी का उपयोग करते हैं कि उपभोक्ता वर्तमान और पिछले दोनों स्कीमा संस्करणों को पढ़ सकें। निम्नलिखित चरणों को पूरा करें:
- निम्न आदेश चलाकर तालिका में एक नया स्तंभ जोड़ें:
- निम्न आदेश चलाकर तालिका में नया डेटा सम्मिलित करें:
- एडब्ल्यूएस गोंद कंसोल पर, चुनें स्कीमा रजिस्ट्रियां नेविगेशन फलक में, फिर चुनें स्कीमा.
- स्कीमा पर नेविगेट करें
db1.sampledatabase.movies
वर्जन 2 आपके द्वारा जोड़े गए कंट्री कॉलम सहित मूवीज टेबल मूवीज के लिए बनाए गए स्कीमा के नए वर्जन की जांच करने के लिए:
- Amazon S3 कंसोल पर, काफ्का विषय फ़ोल्डर में Parquet प्रारूप में लिखे गए डेटा की जाँच करें।
क्लीन अप
अपने AWS खाते में अवांछित शुल्कों को रोकने में मदद के लिए, इस पोस्ट में उपयोग किए गए AWS संसाधनों को हटा दें:
- Amazon S3 कंसोल पर, CloudFormation टेम्प्लेट द्वारा बनाए गए S3 बकेट पर नेविगेट करें।
- सभी फाइलों और फ़ोल्डरों का चयन करें और चुनें मिटाना.
- निर्देशित के रूप में स्थायी रूप से हटाएं दर्ज करें और चुनें वस्तुओं को हटाएं.
- AWS CloudFormation कंसोल पर, आपके द्वारा बनाए गए स्टैक को हटा दें।
- स्टैक की स्थिति बदलने के लिए प्रतीक्षा करें DELETE_COMPLETE.
निष्कर्ष
इस पोस्ट में दिखाया गया है कि Amazon MSK, MSK Connect, और AWS Glue Schema Registry का उपयोग कैसे करें ताकि CDC लॉग स्ट्रीम का निर्माण किया जा सके और डेटा स्ट्रीम के लिए स्कीमा विकसित किया जा सके क्योंकि व्यवसाय को परिवर्तन की आवश्यकता होती है। आप इस आर्किटेक्चर पैटर्न को विभिन्न काफ्का कनेक्टर्स के साथ अन्य डेटा स्रोतों पर लागू कर सकते हैं। अधिक जानकारी के लिए, देखें एमएसके कनेक्ट उदाहरण.
लेखक के बारे में
कल्याण जानकी Amazon Web Services में वरिष्ठ बिग डेटा और एनालिटिक्स विशेषज्ञ हैं। वह AWS पर ग्राहकों को अत्यधिक स्केलेबल, प्रदर्शन करने वाले और सुरक्षित क्लाउड-आधारित समाधान बनाने में मदद करता है।
- एसईओ संचालित सामग्री और पीआर वितरण। आज ही प्रवर्धित हो जाओ।
- प्लेटोब्लॉकचैन। Web3 मेटावर्स इंटेलिजेंस। ज्ञान प्रवर्धित। यहां पहुंचें।
- स्रोत: https://aws.amazon.com/blogs/big-data/build-an-end-to-end-change-data-capture-with-amazon-msk-connect-and-aws-glue-schema-registry/
- :है
- $यूपी
- 1
- 10
- 11
- 7
- 8
- a
- योग्य
- About
- पहुँच
- लेखा
- सही
- स्वीकार करना
- जोड़ा
- इसके अलावा
- सब
- की अनुमति दे
- की अनुमति देता है
- पहले ही
- वीरांगना
- अमेज़ॅन EC2
- अमेज़ॅन वेब सेवा
- विश्लेषिकी
- और
- अपाचे
- अपाचे काफ्का
- अनुप्रयोगों
- लागू करें
- उपयुक्त
- स्थापत्य
- हैं
- AS
- अरोड़ा
- स्वतः
- उपलब्ध
- एडब्ल्यूएस
- एडब्ल्यूएस CloudFormation
- एडब्ल्यूएस गोंद
- BE
- से पहले
- लाभ
- के बीच
- बड़ा
- बड़ा डेटा
- जूते का फीता
- निर्माण
- व्यापार
- by
- कर सकते हैं
- क्षमताओं
- कब्जा
- कैप्चरिंग
- मामलों
- सूची
- सीडीसी
- केंद्रीकृत
- परिवर्तन
- परिवर्तन
- प्रभार
- चेक
- जाँचता
- चुनें
- कक्षा
- समूह
- स्तंभ
- समुदाय
- अनुकूलता
- संगत
- पूरा
- अंग
- गणना करना
- विन्यास
- मिला हुआ
- जुडिये
- संबंध
- कंसोल
- स्थिर
- उपभोग
- उपभोक्ता
- उपभोक्ताओं
- लगातार
- अनुबंध
- नियंत्रण
- देश
- बनाना
- बनाया
- महत्वपूर्ण
- वर्तमान
- रिवाज
- ग्राहक
- तिथि
- डेटा एकीकरण
- डेटा पर ही आधारित
- डाटाबेस
- डेटाबेस
- दिन
- निर्णय
- चूक
- चूक
- परिभाषित
- पहुंचाने
- डेमो
- साबित
- दर्शाता
- तैनात
- तैनात
- विवरण
- गंतव्य
- विस्तृत
- विवरण
- विभिन्न
- अन्य वायरल पोस्ट से
- नहीं करता है
- बूंद
- से प्रत्येक
- को हटा देता है
- समर्थकारी
- शुरू से अंत तक
- सुनिश्चित
- सुनिश्चित
- दर्ज
- वातावरण
- त्रुटि
- विशेष रूप से
- ईथर (ईटीएच)
- प्रत्येक
- विकसित करना
- उदाहरण
- मौजूदा
- मौजूद
- कुछ
- फ़ील्ड
- पट्टिका
- फ़ाइलें
- अंतिम
- प्रथम
- निम्नलिखित
- के लिए
- प्रपत्र
- प्रारूप
- से
- उत्पन्न
- उत्पन्न
- समूह
- समूह की
- संभालना
- हैंडलिंग
- हो जाता
- है
- मदद
- मदद करता है
- अत्यधिक
- इतिहास
- मेजबान
- घंटे
- कैसे
- How To
- एचटीएमएल
- http
- HTTPS
- हब
- आई ए एम
- पहचान
- पहचान
- कार्यान्वयन
- महत्वपूर्ण
- in
- सहित
- अनुक्रमणिका
- करें-
- प्रारंभिक
- स्थापित
- उदाहरण
- बजाय
- एकीकृत
- एकीकरण
- आंतरिक
- IT
- जावा
- जेपीजी
- JSON
- काफ्का
- कुंजी
- जानना
- छोड़ना
- पुस्तकालयों
- लाइसेंस - प्राप्त
- पसंद
- भार
- लोड हो रहा है
- स्थानीय
- लंबा
- बनाया गया
- बनाता है
- निर्माण
- कामयाब
- मास्टर
- मैक्स
- अधिकतम
- तंत्र
- message
- संदेश
- हो सकता है
- मिनट
- आदर्श
- मोड
- पर नज़र रखता है
- अधिक
- चलचित्र
- चलती
- विभिन्न
- MySQL
- नाम
- नेविगेट करें
- पथ प्रदर्शन
- आवश्यकता
- जरूरत
- की जरूरत है
- नेटवर्क
- नया
- अगला
- संख्या
- of
- पुराना
- on
- ONE
- खुला स्रोत
- अन्य
- उत्पादन
- पृष्ठ
- जोड़े
- फलक
- प्राचल
- पैरामीटर
- भाग
- पारित कर दिया
- पासवर्ड
- पैटर्न
- निष्पादन
- हमेशा
- चुनना
- प्लेटो
- प्लेटो डेटा इंटेलिजेंस
- प्लेटोडाटा
- लगाना
- plugins
- पद
- को रोकने के
- पिछला
- प्रक्रिया
- प्रसंस्करण
- उत्पादन
- उत्पादक
- गुण
- प्रदान करना
- बशर्ते
- प्रदान करता है
- पढ़ना
- वास्तविक
- वास्तविक समय
- प्राप्त करना
- रिकॉर्ड
- अभिलेख
- संदर्भित करता है
- क्षेत्र
- रजिस्टर
- पंजीकृत
- रजिस्ट्री
- कोष
- प्रतिनिधित्व
- उपयुक्त संसाधन चुनें
- रिटर्न
- भूमिका
- नियम
- रन
- दौड़ना
- वही
- स्केलेबल
- मूल
- Search
- सेकंड
- सुरक्षित
- सुरक्षा
- वरिष्ठ
- संवेदनशील
- अलग
- सेवा
- सेवाएँ
- सेट
- सेटिंग्स
- चाहिए
- सरल
- को आसान बनाने में
- समाधान
- समाधान ढूंढे
- कुछ
- स्रोत
- सूत्रों का कहना है
- विशेषज्ञ
- विशिष्ट
- विनिर्दिष्ट
- धुआँरा
- शुरुआत में
- स्थिति
- कदम
- कदम
- भंडारण
- की दुकान
- भंडार
- धारा
- स्ट्रीमिंग
- नदियों
- संरचना
- उपयुक्त
- सहायक
- समर्थन करता है
- सिंक।
- प्रणाली
- सिस्टम
- तालिका
- लक्ष्य
- कार्य
- टेम्पलेट
- परीक्षण
- कि
- RSI
- स्रोत
- उन
- इन
- पहर
- संवेदनशील समय
- शीर्षक
- सेवा मेरे
- विषय
- लेनदेन
- मोड़
- प्रकार
- के अंतर्गत
- अवांछित
- अद्यतन
- उपयोग
- उपयोगकर्ता
- मूल्य
- मान
- संस्करण
- वेब
- वेब सेवाओं
- कौन कौन से
- मर्जी
- खिड़कियां
- साथ में
- कामगार
- श्रमिकों
- काम कर रहे
- कार्य
- लिखा हुआ
- आपका
- जेफिरनेट