Amazon MSK সার্ভারলেস, Amazon MSK Connect, এবং MongoDB Atlas এর সাথে একটি সার্ভারহীন স্ট্রিমিং পাইপলাইন তৈরি করুন

এই পোস্টটি মঙ্গোডিবি থেকে বাবু শ্রীনিবাসন এবং রবার্ট ওয়াল্টারদের সাথে লেখা হয়েছে।

Apache Kafka-এর জন্য Amazon পরিচালিত স্ট্রিমিং (Amazon MSK) একটি সম্পূর্ণরূপে পরিচালিত, অত্যন্ত উপলব্ধ Apache Kafka পরিষেবা। Amazon MSK রিয়েল টাইমে স্ট্রিমিং ডেটা গ্রহণ করা এবং প্রক্রিয়া করা সহজ করে এবং সেই ডেটা AWS ইকোসিস্টেমের মধ্যে সহজেই ব্যবহার করে৷ সঙ্গে আমাজন MSK সার্ভারহীন, আপনি স্বয়ংক্রিয়ভাবে আপনার অ্যাপ্লিকেশনগুলির জন্য চাহিদা অনুযায়ী স্ট্রিমিং ক্ষমতা এবং স্টোরেজ প্রদানের জন্য প্রয়োজনীয় সংস্থানগুলি সরবরাহ এবং পরিচালনা করতে পারেন।

Amazon MSK এছাড়াও MongoDB Atlas এর মাধ্যমে ডেটা উৎসগুলির একীকরণ সমর্থন করে আমাজন MSK কানেক্ট. MSK কানেক্ট অ্যামাজন MSK-এর সাথে MongoDB ডেটার সার্ভারহীন একীকরণের অনুমতি দেয় মঙ্গোডিবি সংযোগকারী অ্যাপাচি কাফকার জন্য।

মঙ্গোডিবি অ্যাটলাস সার্ভারহীন ডাটাবেস পরিষেবাগুলি প্রদান করে যা ডাটা সাইজ এবং থ্রুপুট সহ গতিশীলভাবে উপরে এবং নীচে স্কেল করে এবং সেই অনুযায়ী খরচ স্কেল করে। ন্যূনতম কনফিগারেশনের সাথে পরিচালনা করা পরিবর্তনশীল চাহিদা সহ অ্যাপ্লিকেশনগুলির জন্য এটি সবচেয়ে উপযুক্ত। এটি স্বয়ংক্রিয় আপগ্রেড, এনক্রিপশন, নিরাপত্তা, মেট্রিক্স এবং মঙ্গোডিবি অ্যাটলাস পরিকাঠামোর সাথে তৈরি ব্যাকআপ বৈশিষ্ট্যগুলির সাথে উচ্চ কার্যকারিতা এবং নির্ভরযোগ্যতা প্রদান করে।

MSK সার্ভারলেস হল Amazon MSK-এর জন্য এক ধরনের ক্লাস্টার। ঠিক মঙ্গোডিবি অ্যাটলাস সার্ভারলেস এর মতো, এমএসকে সার্ভারলেস স্বয়ংক্রিয়ভাবে বিধান এবং স্কেল গণনা এবং সঞ্চয়স্থান সংস্থান করে। আপনি এখন এন্ড-টু-এন্ড সার্ভারহীন ওয়ার্কফ্লো তৈরি করতে পারেন। আপনি MongoDB Atlas ব্যবহার করে MSK সার্ভারলেস এবং সার্ভারহীন স্টোরেজ ব্যবহার করে সার্ভারহীন ইনজেশন সহ একটি সার্ভারহীন স্ট্রিমিং পাইপলাইন তৈরি করতে পারেন। উপরন্তু, MSK Connect এখন সমর্থন করে ব্যক্তিগত DNS হোস্টনাম. এটি সার্ভারহীন MSK দৃষ্টান্তগুলিকে সার্ভারলেস মঙ্গোডিবি ক্লাস্টারগুলির মাধ্যমে সংযোগ করতে দেয় AWS প্রাইভেট লিঙ্ক, প্ল্যাটফর্মগুলির মধ্যে সুরক্ষিত সংযোগ প্রদান করে৷

আপনি যদি একটি নন-সার্ভারহীন ক্লাস্টার ব্যবহার করতে আগ্রহী হন, তাহলে পড়ুন Apache Kafka (MSK) এর জন্য Amazon পরিচালিত স্ট্রিমিংয়ের সাথে MongoDB একীভূত করা.

এই পোস্টটি দেখায় কিভাবে MSK সার্ভারলেস, MSK কানেক্ট, এবং MongoDB Atlas-এর সাথে সার্ভারহীন স্ট্রিমিং পাইপলাইন বাস্তবায়ন করা যায়।

সমাধান ওভারভিউ

নিম্নলিখিত চিত্রটি আমাদের সমাধান আর্কিটেকচারের চিত্র তুলে ধরেছে।

ডেটা প্রবাহ একটি দিয়ে শুরু হয় অ্যামাজন ইলাস্টিক কম্পিউট ক্লাউড (Amazon EC2) ক্লায়েন্ট উদাহরণ যা একটি MSK বিষয়ে রেকর্ড লেখে। ডেটা আসার সাথে সাথে, অ্যাপাচি কাফকার জন্য মঙ্গোডিবি সংযোগকারীর একটি উদাহরণ মঙ্গোডিবি অ্যাটলাস সার্ভারলেস ক্লাস্টারে একটি সংগ্রহে ডেটা লিখে। দুটি প্ল্যাটফর্মের মধ্যে সুরক্ষিত সংযোগের জন্য, MongoDB Atlas ক্লাস্টার এবং MSK দৃষ্টান্ত ধারণকারী VPC-এর মধ্যে একটি AWS PrivateLink সংযোগ তৈরি করা হয়েছে।

এই পোস্টটি আপনাকে নিম্নলিখিত ধাপে নিয়ে যাবে:

1. সার্ভারহীন MSK ক্লাস্টার তৈরি করুন।
2. MongoDB Atlas Serverless ক্লাস্টার তৈরি করুন।
3. MSK প্লাগইন কনফিগার করুন।
4. EC2 ক্লায়েন্ট তৈরি করুন।
5. একটি MSK বিষয় কনফিগার করুন।
6. Apache Kafka-এর জন্য MongoDB সংযোগকারীকে সিঙ্ক হিসেবে কনফিগার করুন।

সার্ভারহীন MSK ক্লাস্টার কনফিগার করুন

একটি সার্ভারহীন MSK ক্লাস্টার তৈরি করতে, নিম্নলিখিত পদক্ষেপগুলি সম্পূর্ণ করুন:

1. Amazon MSK কনসোলে, বেছে নিন ক্লাস্টার নেভিগেশন ফলকে।
2. বেছে নিন ক্লাস্টার তৈরি করুন.
3. জন্য সৃষ্টি পদ্ধতি, নির্বাচন করুন কাস্টম তৈরি করুন.
4. জন্য গুচ্ছ নামপ্রবেশ করান MongoDBMSKCluster.
5. জন্য ক্লাস্টার টাইপ¸ নির্বাচন করুন Serverless.
6. বেছে নিন পরবর্তী.
7. উপরে নেটওয়ার্কিং পৃষ্ঠায়, আপনার VPC, প্রাপ্যতা অঞ্চল এবং সংশ্লিষ্ট সাবনেট নির্দিষ্ট করুন।
8. পরে ব্যবহার করার জন্য উপলব্ধতা অঞ্চল এবং সাবনেটগুলি নোট করুন।
9. বেছে নিন পরবর্তী.
10. বেছে নিন ক্লাস্টার তৈরি করুন.

যখন ক্লাস্টার পাওয়া যায়, তখন তার অবস্থা হয়ে যায় Active.

MongoDB Atlas Serverless ক্লাস্টার তৈরি করুন

একটি MongoDB Atlas ক্লাস্টার তৈরি করতে, অনুসরণ করুন অ্যাটলাস দিয়ে শুরু করা টিউটোরিয়াল মনে রাখবেন যে এই পোস্টের উদ্দেশ্যে, আপনাকে একটি সার্ভারহীন উদাহরণ তৈরি করতে হবে।

ক্লাস্টার তৈরি হওয়ার পরে, নিম্নলিখিত পদক্ষেপগুলি সহ একটি AWS ব্যক্তিগত শেষ পয়েন্ট কনফিগার করুন:

1. উপরে নিরাপত্তা মেনু, নির্বাচন করুন নেটওয়ার্কের প্রবেশাধিকার.
2. উপরে প্রাইভেট এন্ডপয়েন্ট ট্যাব, চয়ন করুন সার্ভারহীন দৃষ্টান্ত.
   
3. বেছে নিন নতুন এন্ডপয়েন্ট তৈরি করুন.
4. জন্য সার্ভারহীন দৃষ্টান্ত, আপনি এইমাত্র তৈরি করা উদাহরণ নির্বাচন করুন।
5. বেছে নিন নিশ্চিত করা.
6. আপনার VPC এন্ডপয়েন্ট কনফিগারেশন প্রদান করুন এবং নির্বাচন করুন পরবর্তী.
7. AWS PrivateLink রিসোর্স তৈরি করার সময়, সার্ভারহীন MSK ইন্সট্যান্সের জন্য নেটওয়ার্কিং কনফিগারেশন তৈরি করার সময় আপনি ঠিক একই VPC এবং সাবনেটগুলি উল্লেখ করেছেন তা নিশ্চিত করুন।
8. বেছে নিন পরবর্তী.
9. এর নির্দেশাবলী অনুসরণ করুন পাকা করা পৃষ্ঠা, তারপর চয়ন করুন নিশ্চিত করা আপনার VPC এন্ডপয়েন্ট তৈরি হওয়ার পর।

সাফল্যের পরে, নতুন ব্যক্তিগত শেষ পয়েন্ট তালিকায় প্রদর্শিত হবে, যেমনটি নিম্নলিখিত স্ক্রিনশটে দেখানো হয়েছে।

MSK প্লাগইন কনফিগার করুন

এরপর, আমরা Apache Kafka-এর জন্য MongoDB সংযোগকারী ব্যবহার করে Amazon MSK-এ একটি কাস্টম প্লাগইন তৈরি করি। সংযোগকারী একটি আপলোড করা প্রয়োজন আমাজন সিম্পল স্টোরেজ সার্ভিস (Amazon S3) বালতিতে প্লাগইন তৈরি করার আগে। Apache Kafka এর জন্য MongoDB সংযোগকারী ডাউনলোড করতে, পড়ুন একটি সংযোগকারী JAR ফাইল ডাউনলোড করুন.

1. Amazon MSK কনসোলে, বেছে নিন কাস্টমাইজড প্লাগইন নেভিগেশন ফলকে।
2. বেছে নিন কাস্টম প্লাগইন তৈরি করুন.
3. জন্য S3 URI, ডাউনলোড করা সংযোগকারীর S3 অবস্থান লিখুন।
4. বেছে নিন কাস্টম প্লাগইন তৈরি করুন.

একটি EC2 ক্লায়েন্ট কনফিগার করুন

এর পরে, আসুন একটি EC2 উদাহরণ কনফিগার করি। আমরা টপিক তৈরি করতে এবং টপিকের মধ্যে ডেটা সন্নিবেশ করতে এই উদাহরণটি ব্যবহার করি। নির্দেশাবলীর জন্য, বিভাগটি পড়ুন একটি EC2 ক্লায়েন্ট কনফিগার করুন পদে Apache Kafka (MSK) এর জন্য Amazon পরিচালিত স্ট্রিমিংয়ের সাথে MongoDB একীভূত করা.

MSK ক্লাস্টারে একটি বিষয় তৈরি করুন

একটি কাফকা বিষয় তৈরি করতে, আমাদের প্রথমে কাফকা সিএলআই ইনস্টল করতে হবে।

1. ক্লায়েন্ট EC2 উদাহরণে, প্রথমে জাভা ইনস্টল করুন:

sudo yum install java-1.8.0

2. এর পরে, Apache Kafka ডাউনলোড করতে নিম্নলিখিত কমান্ডটি চালান:

wget https://archive.apache.org/dist/kafka/2.6.2/kafka_2.12-2.6.2.tgz

3. নিম্নলিখিত কমান্ডটি ব্যবহার করে টার ফাইলটি আনপ্যাক করুন:

tar -xzf kafka_2.12-2.6.2.tgz

কাফকার ডিস্ট্রিবিউশনে টুল সহ একটি বিন ফোল্ডার রয়েছে যা বিষয়গুলি পরিচালনা করতে ব্যবহার করা যেতে পারে।

4. যান kafka_2.12-2.6.2 ডিরেক্টরি এবং সার্ভারহীন MSK ক্লাস্টারে একটি কাফকা বিষয় তৈরি করতে নিম্নলিখিত কমান্ডটি ইস্যু করুন:

bin/kafka-topics.sh --create --topic sandbox_sync2 --bootstrap-server <BOOTSTRAP SERVER> --command-config=bin/client.properties --partitions 2

আপনি বুটস্ট্র্যাপ সার্ভার এন্ডপয়েন্ট কপি করতে পারেন ক্লায়েন্ট তথ্য দেখুন আপনার সার্ভারহীন MSK ক্লাস্টারের জন্য পৃষ্ঠা।

আপনি এইগুলি অনুসরণ করে IAM প্রমাণীকরণ কনফিগার করতে পারেন নির্দেশাবলী.

সিঙ্ক সংযোগকারী কনফিগার করুন

এখন, মঙ্গোডিবি অ্যাটলাস সার্ভারলেস ইনস্ট্যান্সে ডেটা পাঠাতে একটি সিঙ্ক সংযোগকারী কনফিগার করি।

1. Amazon MSK কনসোলে, বেছে নিন সংযোজকগুলির নেভিগেশন ফলকে।
2. বেছে নিন সংযোগকারী তৈরি করুন.
3. আপনি আগে তৈরি প্লাগইন নির্বাচন করুন.
4. বেছে নিন পরবর্তী.
5. আপনি আগে তৈরি করা সার্ভারহীন MSK দৃষ্টান্ত নির্বাচন করুন।
6. নিম্নলিখিত কোড হিসাবে আপনার সংযোগ কনফিগারেশন লিখুন:

connector.class=com.mongodb.kafka.connect.MongoSinkConnector
key.converter.schema.enable=false
value.converter.schema.enable=false
database=MongoDBMSKDemo
collection=Sink
tasks.max=1
topics=MongoDBMSKDemo.Source
connection.uri=(MongoDB Atlas Connection String Gos Here) value.converter=org.apache.kafka.connect.storage.StringConverter key.converter=org.apache.kafka.connect.storage.StringConverter

নিশ্চিত করুন যে মঙ্গোডিবি অ্যাটলাস সার্ভারলেস ইনস্ট্যান্সের সাথে সংযোগটি AWS PrivateLink-এর মাধ্যমে। আরো তথ্যের জন্য, পড়ুন AWS PrivateLink-এর সাহায্যে একটি MongoDB Atlas ডেটা প্লেনে নিরাপদে অ্যাপ্লিকেশানগুলি সংযুক্ত করা হচ্ছে.

7. মধ্যে অ্যাক্সেস অনুমতি বিভাগ, একটি তৈরি করুন এডাব্লুএস আইডেন্টিটি এবং অ্যাক্সেস ম্যানেজমেন্ট (আইএএম) ভূমিকার সাথে প্রয়োজনীয় বিশ্বাস নীতি.
8. বেছে নিন পরবর্তী.
9. নির্দিষ্ট করুন অ্যামাজন ক্লাউডওয়াচ লগস আপনার লগ বিতরণ বিকল্প হিসাবে.
10. আপনার সংযোগকারী সম্পূর্ণ করুন.

যখন সংযোগকারীর স্থিতি সক্রিয় হয়ে যায়, তখন পাইপলাইন প্রস্তুত।

MSK বিষয়ের মধ্যে তথ্য সন্নিবেশ করান

আপনার EC2 ক্লায়েন্টে, MSK বিষয় ব্যবহার করে ডেটা সন্নিবেশ করুন kafka-console-producer নিম্নরূপ:

bin/kafka-console-producer.sh --topic sandbox_sync2 --bootstrap-server <BOOTSTRAP SERVER> --producer.config=bin/client.properties

কাফকা বিষয় থেকে সার্ভারহীন MongoDB ক্লাস্টারে ডেটা সফলভাবে প্রবাহিত হয়েছে তা যাচাই করতে, আমরা MongoDB Atlas UI ব্যবহার করি।

আপনি কোনো সমস্যায় পড়লে, লগ ফাইলগুলি পরীক্ষা করতে ভুলবেন না। এই উদাহরণে, আমরা Apache Kafka-এর জন্য Amazon MSK এবং MongoDB সংযোগকারী থেকে তৈরি হওয়া ইভেন্টগুলি পড়ার জন্য CloudWatch ব্যবহার করেছি।

পরিষ্কার কর

ভবিষ্যতের চার্জ এড়াতে, আপনার তৈরি সংস্থানগুলি পরিষ্কার করুন৷ প্রথমে, MSK ক্লাস্টার, সংযোগকারী এবং EC2 উদাহরণ মুছুন:

1. Amazon MSK কনসোলে, বেছে নিন ক্লাস্টার নেভিগেশন ফলকে।
2. আপনার ক্লাস্টার এবং উপর নির্বাচন করুন কার্যপ্রণালী মেনু, নির্বাচন করুন মুছে ফেলা.
3. বেছে নিন সংযোজকগুলির নেভিগেশন ফলকে।
4. আপনার সংযোগকারী নির্বাচন করুন এবং নির্বাচন করুন মুছে ফেলা.
5. বেছে নিন কাস্টমাইজড প্লাগইন নেভিগেশন ফলকে।
6. আপনার প্লাগইন নির্বাচন করুন এবং নির্বাচন করুন মুছে ফেলা.
7. Amazon EC2 কনসোলে, নির্বাচন করুন দৃষ্টান্ত নেভিগেশন ফলকে।
8. আপনি যে উদাহরণটি তৈরি করেছেন তা চয়ন করুন।
9. বেছে নিন উদাহরণ রাষ্ট্র, তাহলে বেছে নাও উদাহরণ বন্ধ করুন.
10. উপরে আমাজন ভিপিসি কনসোল, নির্বাচন করুন সমাপ্তি নেভিগেশন ফলকে।
11. আপনার তৈরি করা শেষ বিন্দু নির্বাচন করুন এবং কার্যপ্রণালী মেনু, নির্বাচন করুন VPC এন্ডপয়েন্ট মুছুন.

এখন আপনি Atlas ক্লাস্টার এবং AWS PrivateLink মুছে ফেলতে পারেন:

12. Atlas ক্লাস্টার কনসোলে লগ ইন করুন।
13. মুছে ফেলার জন্য সার্ভারহীন ক্লাস্টারে নেভিগেট করুন।
14. বিকল্প ড্রপ-ডাউন মেনুতে, নির্বাচন করুন ফুরান.
15. নেভিগেট করুন নেটওয়ার্কের প্রবেশাধিকার অধ্যায়.
16. ব্যক্তিগত শেষ পয়েন্ট চয়ন করুন.
17. সার্ভারহীন উদাহরণ নির্বাচন করুন.
18. বিকল্প ড্রপ-ডাউন মেনুতে, নির্বাচন করুন ফুরান.

সারাংশ

এই পোস্টে, আমরা আপনাকে দেখিয়েছি কিভাবে MSK সার্ভারলেস এবং মঙ্গোডিবি অ্যাটলাস সার্ভারলেস ব্যবহার করে একটি সার্ভারহীন স্ট্রিমিং ইনজেশন পাইপলাইন তৈরি করতে হয়। MSK সার্ভারলেস এর সাথে, আপনি স্বয়ংক্রিয়ভাবে প্রয়োজনীয় সংস্থানগুলি সরবরাহ এবং পরিচালনা করতে পারেন। আমরা দুটি পরিষেবাকে নির্বিঘ্নে একীভূত করতে MSK কানেক্টে মোতায়েন করা একটি MongoDB সংযোগকারী ব্যবহার করেছি এবং MSK বিষয়ে নমুনা ডেটা পাঠানোর জন্য একটি EC2 ক্লায়েন্ট ব্যবহার করেছি। MSK Connect এখন সমর্থন করে ব্যক্তিগত DNS হোস্টনাম, আপনাকে পরিষেবাগুলির মধ্যে ব্যক্তিগত ডোমেন নাম ব্যবহার করতে সক্ষম করে৷ এই পোস্টে, সংযোগকারী প্রাপ্যতা অঞ্চল-নির্দিষ্ট ব্যক্তিগত DNS নাম সমাধান করতে VPC-এর ডিফল্ট DNS সার্ভারগুলি ব্যবহার করেছে৷ এই AWS PrivateLink কনফিগারেশন MSK সার্ভারলেস ইনস্ট্যান্স এবং MongoDB Atlas সার্ভারলেস ইনস্ট্যান্সের মধ্যে নিরাপদ এবং ব্যক্তিগত সংযোগের অনুমতি দেয়।

আপনার শেখা চালিয়ে যেতে, নিম্নলিখিত সংস্থানগুলি দেখুন:

লেখক সম্পর্কে

ইগর আলেকসিভ ডেটা এবং অ্যানালিটিক্স ডোমেনে AWS-এর একজন সিনিয়র পার্টনার সলিউশন আর্কিটেক্ট। তার ভূমিকায় ইগর কৌশলগত অংশীদারদের সাথে কাজ করছেন যা তাদের জটিল, AWS-অপ্টিমাইজ করা আর্কিটেকচার তৈরি করতে সহায়তা করছে। AWS-এ যোগদানের আগে, একজন ডেটা/সলিউশন আর্কিটেক্ট হিসেবে তিনি বিগ ডেটা ডোমেনে অনেক প্রকল্প বাস্তবায়ন করেছিলেন, যার মধ্যে হাডুপ ইকোসিস্টেমের বেশ কয়েকটি ডেটা লেক রয়েছে। একজন ডেটা ইঞ্জিনিয়ার হিসাবে তিনি জালিয়াতি সনাক্তকরণ এবং অফিস অটোমেশনে AI/ML প্রয়োগের সাথে জড়িত ছিলেন।

কিরণ ম্যাটি তিনি Amazon Web Services (AWS) এর একজন প্রধান পণ্য ব্যবস্থাপক এবং ক্যালিফোর্নিয়ার পালো অল্টো-এ অবস্থিত Apache Kafka (Amazon MSK) দলের জন্য Amazon পরিচালিত স্ট্রিমিং-এর সাথে কাজ করেন। তিনি পারফরম্যান্স স্ট্রিমিং এবং বিশ্লেষণাত্মক পরিষেবাগুলি তৈরি করার বিষয়ে উত্সাহী যা উদ্যোগগুলিকে তাদের সমালোচনামূলক ব্যবহারের ক্ষেত্রে উপলব্ধি করতে সহায়তা করে।

 বাবু শ্রীনিবাসন MongoDB-এর একজন সিনিয়র পার্টনার সলিউশন আর্কিটেক্ট। তার বর্তমান ভূমিকায়, তিনি AWS এবং MongoDB সমাধানের জন্য প্রযুক্তিগত একীকরণ এবং রেফারেন্স আর্কিটেকচার তৈরি করতে AWS এর সাথে কাজ করছেন। ডাটাবেস এবং ক্লাউড প্রযুক্তিতে তার দুই দশকেরও বেশি অভিজ্ঞতা রয়েছে। তিনি একাধিক ভূগোল জুড়ে একাধিক গ্লোবাল সিস্টেম ইন্টিগ্রেটর (GSIs) এর সাথে কাজ করা গ্রাহকদের প্রযুক্তিগত সমাধান প্রদানের বিষয়ে উত্সাহী।

রবার্ট ওয়াল্টার্স বর্তমানে MongoDB-এর একজন সিনিয়র প্রোডাক্ট ম্যানেজার। MongoDB-এর আগে, রব মাইক্রোসফটে SQL সার্ভার টিমের প্রোগ্রাম পরিচালনা, পরামর্শ এবং প্রযুক্তিগত প্রাক-বিক্রয় সহ বিভিন্ন ভূমিকায় 17 বছর কাটিয়েছেন। রব এসকিউএল সার্ভারের মধ্যে ব্যবহৃত প্রযুক্তির জন্য তিনটি পেটেন্ট সহ-লেখক এবং SQL সার্ভারে বেশ কয়েকটি প্রযুক্তিগত বইয়ের প্রধান লেখক ছিলেন। রব বর্তমানে MongoDB ব্লগে একজন সক্রিয় ব্লগার।

• এসইও চালিত বিষয়বস্তু এবং পিআর বিতরণ। আজই পরিবর্ধিত পান।
• প্লেটোব্লকচেন। Web3 মেটাভার্স ইন্টেলিজেন্স। জ্ঞান প্রসারিত. এখানে প্রবেশ করুন.
• উত্স: https://aws.amazon.com/blogs/big-data/build-a-serverless-streaming-pipeline-with-amazon-msk-serverless-amazon-msk-connect-and-mongodb-atlas/