الشروع في العمل مع أباتشي كافكا
قبل تثبيت Apache Kafka ، يجب أن يكون لديك Java مثبتًا وحساب مستخدم بامتيازات sudo. علاوة على ذلك ، من المستحسن أن يكون لديك ذاكرة وصول عشوائي تبلغ 2 غيغابايت وما فوق للتشغيل السليم لكافكا.
ستوجهك الخطوات التالية حول كيفية تثبيت Apache Kafka.
تثبيت جافا
مطلوب جافا لتثبيت كافكا. تحقق مما إذا كان Ubuntu الخاص بك يحتوي على Java مثبتًا عن طريق التحقق من الإصدار باستخدام الأمر التالي:
$ جافا --إصدار
إذا لم يتم تثبيت Java ، فاستخدم الأوامر التالية لتثبيت Java OpenJDK.
$ سودو ملائم تثبيت الافتراضي- jdk
إنشاء حساب مستخدم
مع تثبيت Java بالفعل ، قم بإنشاء حساب مستخدم غير أساسي. نحتاج أيضًا إلى منحه بعض امتيازات sudo عن طريق إضافة المستخدم إلى مجموعة sudo باستخدام الأمر التالي:
$ سودو adduser linuxhint
$ سودو adduser linuxhint سودو
قم بتسجيل الدخول إلى حساب المستخدم الذي تم إنشاؤه حديثًا.
تركيب كافكا
تحتاج إلى تنزيل أحدث إصدار من Apache Kafka من صفحة التنزيل الرسمية. قم بتنزيل ملفاته الثنائية باستخدام امتداد wget الأمر كما هو موضح في ما يلي:
$ wget https: // downloads.apache.org / كافكا / 3.2.3 / kafka_2.12-3.2.3.tgz 
بمجرد تنزيل الملف الثنائي ، استخرجه باستخدام امتداد الملف يأخذ الأمر ونقل الدليل المستخرج إلى ملف / opt / kafka.
بعد ذلك ، قم بإنشاء ملف مخطوطات systemd ل حارس حديقة الحيوان و ال كافكا الخدمات التي تساعد في بدء وإيقاف الخدمات.
استخدم محررًا من اختيارك لإنشاء البرامج النصية systemd ولصق المحتويات التالية. ابدأ مع Zookeeper:
$ سودو نانو / إلخ / systemd / النظام / خدمة حارس الحديقةالصق ما يلي:
[ وحدة ]وصف = خادم Apache Zookeeper
توثيق = http: // zookeeper.apache.org
يتطلب = network.target remote-fs.target
بعد، بعدما = network.target remote-fs.target
[ خدمة ]
يكتب = بسيط
إكسيكستارت = / يختار، يقرر / كافكا / سلة مهملات / zookeeper-server-start.sh / يختار، يقرر / كافكا / التكوين / zookeeper.properties
إكسيكستوب = / يختار، يقرر / كافكا / سلة مهملات / zookeeper-server-stop.sh
إعادة بدء = غير طبيعي
[ تثبيت ]
مطلوب من قبل = متعدد المستخدمين
حفظ الملف. قم بإنشاء ملف systemd الخاص بكافكا والصق المحتويات التالية:
عند اللصق ، تأكد من تعيين المسار الصحيح لـ Java التي قمت بتثبيتها في نظامك.
[ وحدة ]وصف = خادم أباتشي كافكا
توثيق = http: // kafka.apache.org / Document.html
يتطلب = zookeeper.service
[ خدمة ]
يكتب = بسيط
بيئة = 'JAVA_HOME = / usr / lib / jvm / java-11-openjdk-amd64'
إكسيكستارت = / يختار، يقرر / كافكا / سلة مهملات / kafka-server-start.sh / يختار، يقرر / كافكا / التكوين / server.properties
إكسيكستوب = / يختار، يقرر / كافكا / سلة مهملات / kafka-server-stop.sh
إعادة بدء = غير طبيعي
[ تثبيت ]
مطلوب من قبل = متعدد المستخدمين
بمجرد الانتهاء من ذلك ، قم بتطبيق التغييرات عن طريق إعادة تحميل البرنامج الخفي systemd:
بعد ذلك ، قم بتمكين خدمة Zookeeper وابدأ تشغيلها باستخدام الأوامر التالية:
$ سودو systemctl بدء zookeepe < قوي > ص قوي >
عليك أيضًا أن تفعل الشيء نفسه مع كافكا:
$ سودو systemctl ابدأ kafka
بمجرد بدء الخدمات ، يمكنك التحقق من حالتها قبل إنشاء موضوع في كافكا.
الشيء الجيد في كافكا هو أن هناك نصوصًا متعددة يمكنك استخدامها.
دعونا ننشئ موضوعًا جديدًا باسم لينوكسينت 1 باستخدام kafka-topics.sh البرنامج النصي مع قسم واحد والنسخ المتماثل. استخدم الأمر التالي:
$ سودو -في لينوكسينت / يختار، يقرر / كافكا / سلة مهملات / kafka-topics.sh --خلق - خادم bootstrap المضيف المحلي: 9092 - عامل النسخ 1 - أقسام 1 --عنوان لينوكسينت 1 
لاحظ أن موضوعنا تم إنشاؤه. يمكننا أن نرى الرسالة السابقة للتحقق من ذلك.
بدلاً من ذلك ، يمكنك سرد الموضوعات المتاحة باستخدام ملف -قائمة الخيار في الأمر التالي. يجب أن يعيد الموضوع الذي أنشأناه: S.
$ سودو -في لينوكسينت / يختار، يقرر / كافكا / سلة مهملات / kafka-topics.sh --قائمة - خادم bootstrap المضيف المحلي: 9092 
مع إنشاء موضوع كافكا ، يمكنك البدء في كتابة بيانات التدفقات على Kafka-console-producer.sh وتحقق مما إذا كان ينعكس في ملف Consumer.sh.
افتح قوقعتك وقم بالوصول إلى الموضوع الذي أنشأناه باستخدام المنتج .sh كما هو موضح في ما يلي:
$ سودو -في لينوكسينت / يختار، يقرر / كافكا / سلة مهملات / kafka-console-producer.sh - قائمة الوسيط المضيف المحلي: 9092 --عنوان لينوكسينت 1 
بعد ذلك ، افتح صدفة أخرى وقم بالوصول إلى موضوع كافكا باستخدام Consumer.sh.
مع فتح القذيفتين ، يمكنك إرسال رسالة على وحدة تحكم المنتج. كل ما تكتبه ينعكس في وحدة تحكم المستهلك مما يؤكد أن أباتشي كافكا الخاص بنا يعمل.
استنتاج
باستخدام هذا الدليل ، لديك الآن جميع الخطوات التي يمكنك اتباعها لتثبيت Apache Kafka في Ubuntu 22.04. نأمل أن تكون قد تمكنت من اتباع كل خطوة وتثبيت Apache Kafka الخاص بك وإنشاء موضوعات لتشغيل إنتاج بسيط للمستهلك والمنتج. يمكنك تنفيذ الشيء نفسه في الإنتاج الكبير.