Apache Kafka দিয়ে শুরু করা
Apache Kafka ইনস্টল করার আগে, আপনার অবশ্যই জাভা ইনস্টল থাকতে হবে এবং sudo সুবিধা সহ একটি ব্যবহারকারীর অ্যাকাউন্ট থাকতে হবে। তাছাড়া, কাফকা সঠিকভাবে চালানোর জন্য 2GB বা তার বেশি RAM থাকা বাঞ্ছনীয়।
নিম্নলিখিত পদক্ষেপগুলি আপনাকে কীভাবে Apache Kafka ইনস্টল করতে হয় সে সম্পর্কে গাইড করবে।
জাভা ইনস্টল করা হচ্ছে
কাফকা ইনস্টল করার জন্য জাভা প্রয়োজন। নিম্নলিখিত কমান্ড ব্যবহার করে সংস্করণ পরীক্ষা করে আপনার উবুন্টুতে একটি জাভা ইনস্টল করা আছে কিনা তা পরীক্ষা করুন:
$ জাভা --সংস্করণ
যদি জাভা ইন্সটল না করা থাকে, তাহলে Java OpenJDK ইন্সটল করতে নিম্নলিখিত কমান্ডগুলি ব্যবহার করুন।
$ sudo উপযুক্ত ইনস্টল ডিফল্ট-jdk
একটি ব্যবহারকারী অ্যাকাউন্ট তৈরি করা
জাভা ইতিমধ্যে ইনস্টল করা হলে, একটি নন-রুট ব্যবহারকারী অ্যাকাউন্ট তৈরি করুন। নিম্নলিখিত কমান্ডটি ব্যবহার করে সুডো গ্রুপে ব্যবহারকারীকে যুক্ত করে আমাদের এটিকে কিছু সুডো সুবিধা দিতে হবে:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
নতুন তৈরি ব্যবহারকারী অ্যাকাউন্টে লগ ইন করুন।
কাফকা ইনস্টল করা হচ্ছে
আপনাকে অফিসিয়াল ডাউনলোড পৃষ্ঠা থেকে সর্বশেষ Apache Kafka ডাউনলোড করতে হবে। ব্যবহার করে এর বাইনারি ফাইল ডাউনলোড করুন wget নিম্নলিখিত হিসাবে দেখানো কমান্ড:
$ wget https: // downloads.apache.org / কাফকা / 3.2.3 / kafka_2.12-3.2.3.tgz 
একবার বাইনারি ফাইল ডাউনলোড হয়ে গেলে, এটি ব্যবহার করে এক্সট্র্যাক্ট করুন লাগে কমান্ড এবং নিষ্কাশিত ডিরেক্টরি সরান /অপ্ট/কাফকা।
পরবর্তী, তৈরি করুন সিস্টেমড স্ক্রিপ্ট জন্য চিড়িয়াখানা এবং কাফকা পরিষেবাগুলি যা পরিষেবাগুলি শুরু এবং বন্ধ করতে সহায়তা করে৷
সিস্টেমড স্ক্রিপ্ট তৈরি করতে এবং নিম্নলিখিত বিষয়বস্তু পেস্ট করতে পছন্দের একটি সম্পাদক ব্যবহার করুন। চিড়িয়াখানার সাথে শুরু করুন:
$ sudo ন্যানো / ইত্যাদি / সিস্টেমড / পদ্ধতি / zookeeper.serviceনিম্নলিখিত পেস্ট করুন:
[ ইউনিট ]বর্ণনা =Apache Zookeeper সার্ভার
ডকুমেন্টেশন =http: // zookeeper.apache.org
প্রয়োজন =network.target remote-fs.target
পরে =network.target remote-fs.target
[ সেবা ]
টাইপ = সরল
ExecStart = / অপট / কাফকা / বিন / zookeeper-server-start.sh / অপট / কাফকা / কনফিগারেশন / zookeeper.properties
ExecStop = / অপট / কাফকা / বিন / zookeeper-server-stop.sh
আবার শুরু = অস্বাভাবিক
[ ইনস্টল করুন ]
WantedBy = multi-user.target
ফাইলটি সংরক্ষণ করুন। কাফকার জন্য সিস্টেমড ফাইল তৈরি করুন এবং নিম্নলিখিত বিষয়বস্তু পেস্ট করুন:
পেস্ট করার সময়, নিশ্চিত করুন যে আপনি আপনার সিস্টেমে ইনস্টল করা জাভাটির জন্য সঠিক পথ সেট করেছেন।
[ ইউনিট ]বর্ণনা =অ্যাপাচি কাফকা সার্ভার
ডকুমেন্টেশন =http: // kafka.apache.org / documentation.html
প্রয়োজন = zookeeper.service
[ সেবা ]
টাইপ = সরল
পরিবেশ = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / অপট / কাফকা / বিন / kafka-server-start.sh / অপট / কাফকা / কনফিগারেশন / server.properties
ExecStop = / অপট / কাফকা / বিন / kafka-server-stop.sh
আবার শুরু = অস্বাভাবিক
[ ইনস্টল করুন ]
WantedBy = multi-user.target
একবার হয়ে গেলে, systemd ডেমন পুনরায় লোড করে পরিবর্তনগুলি প্রয়োগ করুন:
এরপরে, Zookeeper পরিষেবা সক্ষম করুন এবং নিম্নলিখিত কমান্ডগুলি ব্যবহার করে এটি শুরু করুন:
$ sudo systemctl শুরু zookeepe < শক্তিশালী > r শক্তিশালী >
আপনাকে কাফকার জন্যও একই কাজ করতে হবে:
$ sudo systemctl শুরু কাফকা
একবার আপনি পরিষেবাগুলি শুরু করলে, আমরা কাফকাতে একটি বিষয় তৈরি করার আগে আপনি তাদের স্থিতি যাচাই করতে পারেন।
কাফকার সাথে ভাল জিনিস হল যে একাধিক স্ক্রিপ্ট রয়েছে যা আপনি ব্যবহার করতে পারেন।
নামে একটি নতুন বিষয় তৈরি করা যাক linuxhint1 ব্যবহার করে kafka-topics.sh একটি পার্টিশন এবং একটি প্রতিলিপি সহ স্ক্রিপ্ট। নিম্নলিখিত কমান্ড ব্যবহার করুন:
$ sudo -ভিতরে লিনাক্সহিন্ট / অপট / কাফকা / বিন / kafka-topics.sh --সৃষ্টি --বুটস্ট্র্যাপ সার্ভার স্থানীয় হোস্ট: 9092 --প্রতিলিপি-কারক 1 --পার্টিশন 1 --বিষয় linuxhint1 
উল্লেখ্য, আমাদের টপিক তৈরি হয়েছে। আমরা তাই যাচাই করতে পূর্ববর্তী বার্তা দেখতে পারেন.
বিকল্পভাবে, আপনি ব্যবহার করে উপলব্ধ বিষয় তালিকা করতে পারেন -তালিকা নিম্নলিখিত কমান্ডে বিকল্প। এটি আমাদের তৈরি করা বিষয় ফিরিয়ে দেওয়া উচিত: এস
$ sudo -ভিতরে লিনাক্সহিন্ট / অপট / কাফকা / বিন / kafka-topics.sh --তালিকা --বুটস্ট্র্যাপ সার্ভার স্থানীয় হোস্ট: 9092 
কাফকা বিষয় তৈরি হওয়ার সাথে সাথে, আপনি স্ট্রিম ডেটা লেখা শুরু করতে পারেন Kafka-console-producer.sh এবং এটি আপনার মধ্যে প্রতিফলিত হয় কিনা তা পরীক্ষা করুন consumer.sh
আপনার শেল খুলুন এবং নিম্নলিখিত হিসাবে দেখানো হয়েছে যেটি আমরা producer.sh ব্যবহার করে তৈরি করেছি তা অ্যাক্সেস করুন:
$ sudo -ভিতরে লিনাক্সহিন্ট / অপট / কাফকা / বিন / kafka-console-producer.sh --ব্রোকার-তালিকা স্থানীয় হোস্ট: 9092 --বিষয় linuxhint1 
এরপর, আরেকটি শেল খুলুন এবং consumer.sh ব্যবহার করে কাফকা বিষয় অ্যাক্সেস করুন।
দুটি শেল খোলার সাথে, আপনি প্রযোজক কনসোলে বার্তা পাঠাতে পারেন। আপনি যা টাইপ করেন তা গ্রাহক কনসোলে প্রতিফলিত হয় তা নিশ্চিত করে যে আমাদের Apache Kafka চালু আছে।
উপসংহার
এই নির্দেশিকাটির সাহায্যে, আপনার উবুন্টু 22.04 এ Apache Kafka ইনস্টল করার জন্য আপনি অনুসরণ করতে পারেন এমন সমস্ত পদক্ষেপ রয়েছে। আশা করি, আপনি প্রতিটি পদক্ষেপ অনুসরণ করতে এবং আপনার Apache Kafka ইনস্টল করতে এবং একটি সাধারণ ভোক্তা এবং প্রযোজক উত্পাদন চালানোর জন্য বিষয়গুলি তৈরি করতে পরিচালনা করেছেন৷ আপনি বড় উত্পাদন একই বাস্তবায়ন করতে পারেন.