از طریق منوی جستجو مطلب مورد نظر خود در وبلاگ را به سرعت پیدا کنید
سرفصلهای مطلب
آپاچی کافکا یک پلت فرم استریم است که توسط بنیاد نرم افزار آپاچی توسعه یافته است. این پلتفرم منبع باز و توزیع شده است و قابل نصب است روی هر پلتفرمی به شرط اینکه از جاوا پشتیبانی کند. علاوه بر این، آپاچی کافکا به زبان جاوا و اسکالا نوشته شده است. این راهنما به شما کمک می کندon آموزش روی روش نصب آپاچی کافکا در اوبونتو 22.04.
شروع کار با آپاچی کافکا
قبل از نصب آپاچی کافکا، باید جاوا را نصب کرده و یک حساب کاربری با امتیازات sudo داشته باشید. علاوه بر این، برای اجرای صحیح کافکا، داشتن رم 2 گیگابایتی و بالاتر توصیه می شود.
مراحل زیر شما را راهنمایی می کند روی روش نصب آپاچی کافکا
نصب جاوا
برای نصب کافکا به جاوا نیاز است. با بررسی نسخه با استفاده از دستور زیر، بررسی کنید که آیا اوبونتو شما یک جاوا نصب کرده است:
$ جاوا –نسخه
اگر جاوا نصب نیست، از دستورات زیر برای نصب Java OpenJDK استفاده کنید.
$ سودو آپدیت مناسب
$ سودو apt نصب پیش فرض-jdk
ایجاد یک حساب کاربری
با نصب جاوا از قبل، یک حساب کاربری غیر ریشه ایجاد کنید. همچنین باید با افزودن کاربر به گروه sudo با استفاده از دستور زیر، برخی از امتیازات sudo را به آن بدهیم:
$ سودو adduser linuxhin
$ سودو adduser linuxhin سودو
به حساب کاربری تازه ایجاد شده وارد شوید.
$ سو -ل لینوشینت
نصب کافکا
شما باید آخرین آپاچی کافکا را از دانلود رسمی دانلود کنید page. فایل های باینری آن را با استفاده از wget دستور همانطور که در زیر نشان داده شده است:
$ wget https://downloads.apache.org/کافکا/3.2.3/kafka_2.12-3.2.3.tgz
پس از دانلود فایل باینری، آن را با استفاده از تار دستور داده و دایرکتوری استخراج شده را به /opt/kafka.
بعد، ایجاد کنید اسکریپت های سیستمی برای نگهبان باغ وحش و کافکا خدماتی که به شروع و توقف خدمات کمک می کند.
از یک ویرایشگر انتخابی برای ایجاد اسکریپت های systemd استفاده کنید و مطالب زیر را جایگذاری کنید. با نگهبان باغ وحش شروع کنید:
$ سودو نانو /و غیره/سیستم شده/سیستم/باغ وحش.سرویس
موارد زیر را بچسبانید:
[Unit]
شرح=سرور Apache Zookeeper
Documentation=http://zookeeper.apache.org
نیاز دارد=network.target remote-fs.target
بعد از=network.target remote-fs.target
[Service]
تایپ کنید=ساده
ExecStart=/انتخاب کردن/کافکا/صندوقچه/zookeeper-server-start.sh /انتخاب کردن/کافکا/پیکربندی/باغ وحش.خواص
ExecStop=/انتخاب کردن/کافکا/صندوقچه/zookeeper-server-stop.sh
راه اندازی مجدد=روی-غیرطبیعی
[Install]
تحت تعقیب=multi-user.target
فایل را ذخیره کنید. فایل systemd را برای کافکا ایجاد کنید و محتویات زیر را در آن قرار دهید:
$ سودو نانو /و غیره/سیستم شده/سیستم/kafka.service
هنگام چسباندن، مطمئن شوید که مسیر درستی را برای جاوای که در سیستم خود نصب کرده اید تنظیم کرده اید.
[Unit]
شرح=سرور آپاچی کافکا
Documentation=http://kafka.apache.org/documentation.html
نیاز دارد=zookeeper.service
[Service]
تایپ کنید=ساده
محیط=“JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64”
ExecStart=/انتخاب کردن/کافکا/صندوقچه/kafka-server-start.sh /انتخاب کردن/کافکا/پیکربندی/server.properties
ExecStop=/انتخاب کردن/کافکا/صندوقچه/kafka-server-stop.sh
راه اندازی مجدد=روی-غیرطبیعی
[Install]
تحت تعقیب=multi-user.target
پس از انجام، تغییرات را با بارگیری مجدد دیمون systemd اعمال کنید:
$ سودو systemctl daemon-reload
سپس سرویس Zookeeper را فعال کرده و با استفاده از دستورات زیر آن را شروع کنید:
$ سودو systemctl فعال کردن نگهبان باغ وحش
$ سودو systemctl zookeepe را شروع کنید<قوی>rقوی>
شما همچنین باید همین کار را برای کافکا انجام دهید:
$ سودو systemctl فعال کردن کافکا
$ سودو systemctl راه اندازی کافکا
هنگامی که خدمات را شروع کردید، می توانید وضعیت آنها را قبل از ایجاد موضوع در کافکا تأیید کنید.
خوبی کافکا این است که چندین اسکریپت وجود دارد که می توانید از آنها استفاده کنید.
بیایید یک موضوع جدید به نام ایجاد کنیم linuxhint1 با استفاده از kafka-topics.sh اسکریپت با یک پارتیشن و یک تکرار. از دستور زیر استفاده کنید:
$ سودو -u لینوشینت /انتخاب کردن/کافکا/صندوقچه/kafka-topics.sh –ایجاد کردن –bootstrap-server localhost:9092 – ضریب تکرار 1 — پارتیشن ها 1 –موضوع linuxhint1
توجه داشته باشید که موضوع ما ایجاد شده است. ما می توانیم پیام قبلی را برای تأیید آن ببینیم.
همچنین، می‌توانید موضوعات موجود را با استفاده از فهرست فهرست کنید -فهرست گزینه در دستور زیر باید موضوعی را که ایجاد کردیم برگرداند:S
$ سودو -u لینوشینت /انتخاب کردن/کافکا/صندوقچه/kafka-topics.sh — لیست –bootstrap-server localhost:9092
با ایجاد موضوع کافکا، می توانید شروع به نوشتن داده های جریان کنید روی را کافکا-console-producer.sh و بررسی کنید که آیا آن را در شما منعکس می کند مصرف کننده.ش.
پوسته خود را باز کنید و به موضوعی که با استفاده از producer.sh ایجاد کردیم، همانطور که در زیر نشان داده شده است دسترسی پیدا کنید:
$ سودو -u لینوشینت /انتخاب کردن/کافکا/صندوقچه/کافکا-console-producer.sh — فهرست کارگزار localhost:9092 –موضوع linuxhint1
بعد یک پوسته دیگر باز کنید و با استفاده از customers.sh به تاپیک کافکا دسترسی پیدا کنید.
$ سودو -u لینوشینت /انتخاب کردن/کافکا/صندوقچه/کافکا-console-consumer.sh –bootstrap-server localhost:9092 –موضوع linuxhint1 –از ابتدا
با باز شدن دو پوسته، می توانید پیام دهید روی تولید کننده console. هر چه تایپ کنید در مصرف کننده منعکس می شود console تایید می کند که آپاچی کافکا ما راه اندازی شده است.
نتیجه
با این راهنما، اکنون تمام مراحلی را دارید که می توانید برای نصب آپاچی کافکا در اوبونتو 22.04 دنبال کنید. امیدوارم موفق شده باشید هر مرحله را دنبال کنید و آپاچی کافکا خود را نصب کرده و موضوعاتی را برای اجرای یک تولید ساده مصرف کننده و تولید کننده ایجاد کنید. شما می توانید همان را در تولید بزرگ پیاده سازی کنید.
برای نگارش بخشهایی از این متن ممکن است از ترجمه ماشینی یا هوش مصنوعی GPT استفاده شده باشد
لطفا در صورت وجود مشکل در متن یا مفهوم نبودن توضیحات، از طریق دکمه گزارش نوشتار یا درج نظر روی این مطلب ما را از جزییات مشکل مشاهده شده مطلع کنید تا به آن رسیدگی کنیم
لطفا در صورت وجود مشکل در متن یا مفهوم نبودن توضیحات، از طریق دکمه گزارش نوشتار یا درج نظر روی این مطلب ما را از جزییات مشکل مشاهده شده مطلع کنید تا به آن رسیدگی کنیم
زمان انتشار: 1402-12-29 18:00:04
