نحوه نصب Apache Kafka در CentOS 7

Apache Kafka یک سیستم پیام رسانی مقیاس پذیر و پرقدرت است که قادر به دستیابی به کارآمد با حجم عظیمی از داده ها است.

برای عملکرد بیشتر می توانید Kafka را روی یک سرور مستقر کنید یا یک خوشه توزیع شده کافکا را بسازید. به عنوان یک مبتدی ، این مقاله نحوه نصب Apache Kafka را در یک نمونه سرور Vultr CentOS 7 تنها توضیح می دهد.

پیش نیازها:

قبل از حرکت ، باید:

  • نمونه سرور Vultr CentOS 7 را مستقر کنید. بسته به نیاز شما ، ممکن است نیاز به افزایش حافظه موجود داشته باشید.
  • برای ورود از ترمینال SSH از یک کاربر sudo استفاده کنید.

مرحله 1: سیستم CentOS 7 را به روز کنید

از دستور زیر برای به روزرسانی سیستم خود به آخرین وضعیت پایدار استفاده کنید:

sudo yum update -y && sudo reboot

پس از اتمام راه اندازی مجدد ، از همان کاربر sudo استفاده کنید تا دوباره وارد سیستم شوید.

مرحله 2: OpenJDK Runtime را نصب کنید

قبل از اجرای صحیح Apache Kafka باید یک سیستم مجازی جاوا را روی سیستم خود تنظیم کنید. در اینجا می توانید OpenJDK Runtime Environment 1.8.0 را با استفاده از YUM نصب کنید:

sudo yum install java-1.8.0-openjdk.x86_64

نصب خود را با:

java -version

خروجی باید شبیه باشد:

openjdk version "1.8.0_91"
OpenJDK Runtime Environment (build 1.8.0_91-b14)
OpenJDK 64-Bit Server VM (build 25.91-b14, mixed mode)

همچنین باید متغیرهای محیط "JAVA_HOME" و "JRE_HOME" را تنظیم کنید:

sudo vi /etc/profile

خطوط زیر را به محتوای اصلی پرونده اضافه کنید:

export JAVA_HOME=/usr/lib/jvm/jre-1.8.0-openjdk
export JRE_HOME=/usr/lib/jvm/jre

ذخیره نموده و خارج شوید:

:wq

بارگیری نمایه برای اعمال تغییرات:

source /etc/profile

مرحله 3: آپاچی کافکا را بارگیری کنید

آخرین نسخه پایدار آپاچی کافکا را از وب سایت رسمی بارگیری کنید. در زمان نوشتن ، آن است 0.9.0.1.

cd ~
wget http://www-us.apache.org/dist/kafka/0.9.0.1/kafka_2.11-0.9.0.1.tgz

بایگانی را از یک مکان دلخواه مانند موارد /optزیر جدا کنید:

tar -xvf kafka_2.11-0.9.0.1.tgz
sudo mv kafka_2.11-0.9.0.1 /opt

مرحله 4: آپاچی کافکا را شروع و تست کنید

در این مرحله Apache Kafka روی سیستم شما موجود است. بیایید آن را به یک درایو تست.

4.1: وارد فهرست کافکا شوید

cd /opt/kafka_2.11-0.9.0.1

4.2: سرور Zookeeper را شروع کنید

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

4.3: پیکربندی سرور کافکا را اصلاح کنید

 vi bin/kafka-server-start.sh

میزان حافظه را مطابق با پارامترهای خاص سیستم خود تنظیم کنید. به عنوان مثال ، اگر از نمونه سرور Vultr با حافظه 768MB در محیط آزمایش استفاده می کنید ، باید خط زیر را پیدا کنید:

export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"

آن را جایگزین کنید با:

export KAFKA_HEAP_OPTS="-Xmx256M -Xms128M"

ذخیره انصراف:

:wq

4.4: سرور کافکا را شروع کنید

bin/kafka-server-start.sh config/server.properties

اگر همه چیز با موفقیت پیش رفت ، چندین پیام در مورد وضعیت سرور کافکا را مشاهده خواهید کرد ، و آخرین آن را خواهید خواند:

INFO [Kafka Server 0], started (kafka.server.KafkaServer)

این بدان معنی است که شما سرور کافکا را راه اندازی کرده اید.

4.5: یک موضوع "تست" را در اتصال جدید SSH ایجاد کنید

اتصال SSH جدید را باز کنید ، از دستورات زیر برای ایجاد مبحث "تست" استفاده کنید:

cd /opt/kafka_2.11-0.9.0.1
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

می توانید موضوعات خود را با دستور زیر مشاهده کنید:

bin/kafka-topics.sh --list --zookeeper localhost:2181

در مورد ما ، خروجی می خواند:

test

4.6: تولید پیام با استفاده از موضوع "تست"

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

با استفاده از دستور فوق ، می توانید هر تعداد پیام را به دلخواه خود وارد کنید ، مانند:

Welcome aboard!
Bonjour!

اگر خطایی مشابه "WARN Error while fetching metadata with correlation id"هنگام وارد کردن پیام دریافت کردید ، باید server.propertiesفایل را با اطلاعات زیر به روز کنید:

port = 9092
advertised.host.name = localhost 

4.7: نمایش پیام ها

اتصال SSH سوم را باز کرده و دستورات زیر را اجرا کنید:

cd /opt/kafka_2.11-0.9.0.1
bin/kafka-console-consumer.sh --zookeeper localhost:9092 --topic test --from-beginning

تا-دا! پیام هایی که قبلاً تولید کرده اید در سومین اتصال SSH نمایش داده می شود. البته اگر اکنون پیام دوم بیشتری را از اتصال SSH دوم وارد کنید ، بلافاصله آنها را در سومین اتصال SSH مشاهده خواهید کرد.

در آخر ، برای متوقف کردن این اسکریپت ها می توانید Ctrl + C را روی هر اتصال SSH فشار دهید.

خودشه. می توانید اطلاعات بیشتری در مورد آپاچی کافکا در وب سایت رسمی کسب کنید. خوش بگذره!



Leave a Comment

نحوه بروزرسانی CentOS 7 ، Ubuntu 16.04 و Debian 8

نحوه بروزرسانی CentOS 7 ، Ubuntu 16.04 و Debian 8

هنگام راه اندازی سرور جدید لینوکس ، به روزرسانی سیستم های هسته و سایر بسته ها تا آخرین نسخه پایدار یک روش توصیه شده است. در این مقاله

تنظیم RethinkDB Cluster On CentOS 7

تنظیم RethinkDB Cluster On CentOS 7

مقدمه RethinkDB یک پایگاه داده NoSQL است که داده ها را به عنوان اسناد JSON ذخیره می کند. این یک زبان پرس و جو بسیار بصری است و از ویژگی های آن معمولا در دسترس است

نحوه نصب نسخه باز Vtiger CRM در CentOS 7

نحوه نصب نسخه باز Vtiger CRM در CentOS 7

Vtiger CRM یک نرم افزار محبوب مدیریت ارتباط با مشتری است که می تواند به بنگاهها در رشد فروش ، ارائه خدمات به مشتری و افزایش سود کمک کند. من

نحوه نصب کاناپه CMS 2.0 بر روی یک VPS CentOS 7 LAMP

نحوه نصب کاناپه CMS 2.0 بر روی یک VPS CentOS 7 LAMP

با استفاده از یک سیستم متفاوت؟ Couch CMS یک سیستم مدیریت محتوای منبع ساده و انعطاف پذیر ، آزاد و منبع باز (CMS) است که به طراحان وب اجازه می دهد تا طراحی کنند.

نحوه نصب SonarQube در CentOS 7

نحوه نصب SonarQube در CentOS 7

با استفاده از یک سیستم متفاوت؟ SonarQube یک ابزار منبع باز برای توسعه سیستم با کیفیت است. در جاوا نوشته شده است و چندین پایگاه داده را پشتیبانی می کند. فراهم می کند

نصب Netdata در CentOS 7

نصب Netdata در CentOS 7

با استفاده از یک سیستم متفاوت؟ Netdata یک ستاره در حال افزایش در زمینه نظارت بر معیارهای سیستم در زمان واقعی است. در مقایسه با سایر ابزارهای مشابه ، Netdata:

نحوه فعال سازی پشتیبانی HTTP / 2 در DirectAdmin (CentOS)

نحوه فعال سازی پشتیبانی HTTP / 2 در DirectAdmin (CentOS)

HTTP / 2 جدیدترین نسخه پروتکل HTTP است که از SPDY مستقر است. توسعه آن توسط Google آغاز شده است و HTTP / 2 تا حد زیادی بر اساس پایگاه کد است

نحوه نصب سرور Starbound در CentOS 7

نحوه نصب سرور Starbound در CentOS 7

با استفاده از یک سیستم متفاوت؟ در این آموزش ، Ill در مورد نحوه راه اندازی یک سرور Starbound در CentOS 7 توضیح می دهد. پیش نیازها: شما باید این بازی را روی خود داشته باشید

یک سرور چند نفره SA-MP San Andreas را در CentOS 6 تنظیم کنید

یک سرور چند نفره SA-MP San Andreas را در CentOS 6 تنظیم کنید

به یکی دیگر از آموزش های Vultr خوش آمدید. در اینجا ، نحوه نصب و اجرای سرور SAMP را یاد خواهید گرفت. این راهنما برای CentOS 6 نوشته شده است. پیش نیازهای مورد نیاز شما

Elgg را روی CentOS 7 نصب کنید

Elgg را روی CentOS 7 نصب کنید

با استفاده از یک سیستم متفاوت؟ Elgg یک موتور شبکه ای منبع باز است که امکان ایجاد محیط های اجتماعی از جمله شبکه های اجتماعی دانشگاه را فراهم می کند

نحوه نصب سرور RStudio در CentOS 7

نحوه نصب سرور RStudio در CentOS 7

RStudio Server نسخه وب RStudio است که مجموعه ای از ابزارهایی است که برای تسهیل کار برنامه نویسی با استفاده از زبان برنامه نویسی R طراحی شده است. در سه

نصب Bolt CMS در CentOS 7

نصب Bolt CMS در CentOS 7

Bolt یک CMS منبع باز است که به زبان PHP نوشته شده است. کد منبع Bolts در GitHub میزبانی شده است. این راهنما نحوه نصب Bolt CMS را در CentOS 7 Vult تازه نشان می دهد

نحوه نصب Elasticsearch در سرور Vultr CentOS 7

نحوه نصب Elasticsearch در سرور Vultr CentOS 7

Elasticsearch یک موتور جستجوی کامل و متن تحلیلی متن کامل است. به لطف تطبیق پذیری ، مقیاس پذیری و سهولت استفاده ، Elasticsearch گسترده تر است

Kubernetes With Kubeadm را در CentOS 7 مستقر کنید

Kubernetes With Kubeadm را در CentOS 7 مستقر کنید

بررسی اجمالی این مقاله به شما کمک می کند تا در هر زمان خوشه ای از Kubernetes را جمع کنید و با kubeadm در حال اجرا باشید. در این راهنما از دو سرور استفاده می شود

راه اندازی Sails.js برای توسعه در CentOS 7

راه اندازی Sails.js برای توسعه در CentOS 7

با استفاده از یک سیستم متفاوت؟ مقدمه Sails.js یک چارچوب MVC ��رای Node.js است ، شبیه به Ruby on Rails. این امر برای ایجاد برنامه های مدرن ver

پیکربندی BGP با استفاده از Quagga در Vultr (CentOS 7)

پیکربندی BGP با استفاده از Quagga در Vultr (CentOS 7)

Vultrs عملکرد IP فضای شما را امکان پذیر می سازد تا آزادی بی سابقه ای در اختصاص منابع IP شخصی شما به سرورهای cloud Vultr داشته باشید. ما کلی

نحوه نصب PufferPanel (کنترل پنل کنکوری رایگان) در CentOS 7

نحوه نصب PufferPanel (کنترل پنل کنکوری رایگان) در CentOS 7

مقدمه در این آموزش ، PufferPanel را در Vultr VPS ما نصب کنید. PufferPanel یک پانل کنترل با منبع آزاد و بصورت رایگان برای مدیریت شما است

ابزارهای نظارت بهتر برای اوبونتو و CentOS

ابزارهای نظارت بهتر برای اوبونتو و CentOS

معرفی سیستم های لینوکس به طور پیش فرض مانند top ، df و du با ابزارهای نظارتی ارسال می شوند که به نظارت بر فرایندها و فضای دیسک کمک می کنند. با این حال ، اغلب اوقات ، آنها به صورت طاقت فرسا هستند

دستگاه های خود را با استفاده از LibreNMS در CentOS 7 نظارت کنید

دستگاه های خود را با استفاده از LibreNMS در CentOS 7 نظارت کنید

با استفاده از یک سیستم متفاوت؟ LibreNMS یک سیستم نظارت بر شبکه منبع باز کاملاً برجسته است. از SNMP برای به دست آوردن داده ها از دستگاه های مختلف استفاده می کند. یک نوع

نحوه نصب Gitea در CentOS 7

نحوه نصب Gitea در CentOS 7

با استفاده از یک سیستم متفاوت؟ Gitea یک منبع کنترل جایگزین متن باز و خود میزبان است که توسط Git ساخته شده است. Gitea در Golang نوشته شده و هست

نحوه نصب بستر سبد خرید LiteCart در اوبونتو 16.04

نحوه نصب بستر سبد خرید LiteCart در اوبونتو 16.04

LiteCart یک بستر سبد خرید آزاد و منبع باز است که به زبان های PHP ، jQuery و HTML 5 نوشته شده است. این نرم افزار ساده ، سبک و با کاربرد آسان است.

نحوه نصب Anchor CMS بر روی یک VPS Fedora 26 LAMP

نحوه نصب Anchor CMS بر روی یک VPS Fedora 26 LAMP

با استفاده از یک سیستم متفاوت؟ Anchor CMS یک سیستم مدیریت محتوا (CMS) بسیار ساده و بسیار سبک ، بسیار آزاد و آزاد است.

اشتراک NFS را در Debian تنظیم کنید

اشتراک NFS را در Debian تنظیم کنید

NFS یک سیستم فایل مبتنی بر شبکه است که به رایانه ها اجازه می دهد تا از طریق شبکه رایانه ای به فایلها دسترسی پیدا کنند. این راهنما توضیح می دهد که چگونه می توانید پوشه ها را روی NF قرار دهید

نحوه بروزرسانی CentOS 7 ، Ubuntu 16.04 و Debian 8

نحوه بروزرسانی CentOS 7 ، Ubuntu 16.04 و Debian 8

هنگام راه اندازی سرور جدید لینوکس ، به روزرسانی سیستم های هسته و سایر بسته ها تا آخرین نسخه پایدار یک روش توصیه شده است. در این مقاله

نحوه نصب Matomo Analytics در Fedora 28

نحوه نصب Matomo Analytics در Fedora 28

با استفاده از یک سیستم متفاوت؟ Matomo (سابقا پیویک) یک بستر تحلیلی منبع باز است ، یک جایگزین باز برای Google Analytics. منبع Matomo میزبان o

یک سرور TeamTalk را در لینوکس تنظیم کنید

یک سرور TeamTalk را در لینوکس تنظیم کنید

TeamTalk یک سیستم کنفرانس است که به کاربران امکان می دهد مکالمات صوتی / تصویری با کیفیت بالا ، چت متنی ، انتقال فایل ها و صفحه های به اشتراک بگذارند. من

با استفاده از کلید SSH خود برای ورود به کاربران غیر ریشه استفاده کنید

با استفاده از کلید SSH خود برای ورود به کاربران غیر ریشه استفاده کنید

Vultr یک ویژگی را فراهم می کند که به شما امکان می دهد با ایجاد یک نمونه جدید ، کلیدهای SSH را از قبل نصب کنید. این اجازه می دهد تا به کاربر root دسترسی داشته باشید ، با این حال ، th

نحوه نصب انجمن NodeBB در FreeBSD 12

نحوه نصب انجمن NodeBB در FreeBSD 12

با استفاده از یک سیستم متفاوت؟ NodeBB یک نرم افزار انجمن مبتنی بر Node.js است. از سوکت های وب برای تعامل فوری و اعلامیه های زمان واقعی استفاده می کند. NodeB

نصب و راه اندازی ZNC در اوبونتو

نصب و راه اندازی ZNC در اوبونتو

ZNC یک پیشرانه پیشرفته شبکه IRC است که تمام وقت بهم متصل می شود تا مشتری IRC بتواند بدون از دست دادن جلسه گپ قطع یا وصل شود.

نحوه نصب Ranger Terminal File Manager در لینوکس

نحوه نصب Ranger Terminal File Manager در لینوکس

رنجر یک مدیر فایل مبتنی بر خط فرمان است که دارای کلیدهای اتصال VI است. این برنامه یک رابط لعنتی مینیمالیستی و زیبا با نمای سلسله مراتب فهرست ارائه می دهد