كيفية تثبيت Apache Kafka في Ubuntu 22.04

Kyfyt Tthbyt Apache Kafka Fy Ubuntu 22 04

Apache Kafka عبارة عن منصة بث تم تطويرها بواسطة مؤسسة Apache Software. النظام الأساسي مفتوح المصدر وموزع ، ويمكن تثبيته على أي نظام أساسي بشرط أن يدعم Java. إلى جانب ذلك ، فإن Apache Kafka مكتوب بلغة Java و Scala. يقدم هذا الدليل تعليميًا عمليًا حول كيفية تثبيت Apache Kafka في Ubuntu 22.04.

الشروع في العمل مع أباتشي كافكا

قبل تثبيت 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 الخاص بكافكا والصق المحتويات التالية:

$ سودو نانو / إلخ / 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:

$ سودو إعادة تحميل البرنامج الخفي systemctl


بعد ذلك ، قم بتمكين خدمة Zookeeper وابدأ تشغيلها باستخدام الأوامر التالية:

$ سودو systemctl يُمكَِن حارس حديقة الحيوان

$ سودو systemctl بدء zookeepe < قوي > ص قوي >


عليك أيضًا أن تفعل الشيء نفسه مع كافكا:

$ سودو systemctl يُمكَِن كافكا

$ سودو 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.

$ سودو -في لينوكسينت / يختار، يقرر / كافكا / سلة مهملات / kafka-console-consumer.sh - خادم bootstrap المضيف المحلي: 9092 --عنوان لينوكسينت 1 --من البداية


مع فتح القذيفتين ، يمكنك إرسال رسالة على وحدة تحكم المنتج. كل ما تكتبه ينعكس في وحدة تحكم المستهلك مما يؤكد أن أباتشي كافكا الخاص بنا يعمل.

استنتاج

باستخدام هذا الدليل ، لديك الآن جميع الخطوات التي يمكنك اتباعها لتثبيت Apache Kafka في Ubuntu 22.04. نأمل أن تكون قد تمكنت من اتباع كل خطوة وتثبيت Apache Kafka الخاص بك وإنشاء موضوعات لتشغيل إنتاج بسيط للمستهلك والمنتج. يمكنك تنفيذ الشيء نفسه في الإنتاج الكبير.