Si të instaloni Apache Kafka në CentOS 7

Apache Kafka është një sistem mesazhesh i shkallëzuar dhe me performancë të lartë, i cili është në gjendje të trajtojë me efikasitet një sasi të madhe të dhënash.

Ju ose mund të vendosni Kafka në një server ose të ndërtoni një grup të shpërndarë Kafka për performancë më të madhe. Si fillim, ky artikull shpjegon se si të instaloni Apache Kafka në një shembull të vetëm të serverit Vultr CentOS 7.

Kushtet paraprake:

Përpara se të vazhdoni, duhet:

  • Vendosni një shembull të serverit Vultr CentOS 7. Në varësi të nevojave tuaja, mund t'ju duhet të rrisni memorien e disponueshme.
  • Përdorni një përdorues sudo për t'u identifikuar nga terminali juaj SSH.

Hapi 1: Përditësoni sistemin CentOS 7

Përdorni komandën e mëposhtme për të përditësuar sistemin tuaj në statusin më të fundit të qëndrueshëm:

sudo yum update -y && sudo reboot

Pasi të ketë mbaruar rindezja, përdorni të njëjtin përdorues sudo për t'u identifikuar përsëri.

Hapi 2: Instaloni OpenJDK Runtime

Ju duhet të konfiguroni një makinë virtuale Java në sistemin tuaj përpara se të mund të ekzekutoni Apache Kafka siç duhet. Këtu mund të instaloni OpenJDK Runtime Environment 1.8.0 duke përdorur YUM:

sudo yum install java-1.8.0-openjdk.x86_64

Vërtetoni instalimin tuaj me:

java -version

Prodhimi duhet të ngjajë:

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)

Ju gjithashtu duhet të konfiguroni variablat e mjedisit "JAVA_HOME" dhe "JRE_HOME":

sudo vi /etc/profile

Shtojini rreshtat e mëposhtëm në përmbajtjen origjinale të skedarit:

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

Ruani dhe hiqni dorë:

:wq

Ringarko profilin për të vënë në fuqi ndryshimet e tua:

source /etc/profile

Hapi 3: Shkarkoni Apache Kafka

Shkarkoni versionin më të fundit të qëndrueshëm të Apache Kafka nga faqja zyrtare e internetit. Në kohën e shkrimit, është 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

Unzip arkiv në një vend të preferuar, të tilla si /opt:

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

Hapi 4: Filloni dhe provoni Apache Kafka

Në këtë pikë, Apache Kafka është i disponueshëm në sistemin tuaj. Le t'i bëjmë një provë.

4.1: Hyni në drejtorinë Kafka

cd /opt/kafka_2.11-0.9.0.1

4.2: Nisni serverin Zookeeper

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

4.3: Ndryshoni konfigurimin e serverit tuaj Kafka

 vi bin/kafka-server-start.sh

Rregulloni përdorimin e memories sipas parametrave të sistemit tuaj specifik. Për shembull, nëse jeni duke përdorur një shembull të serverit Vultr me memorie 768 MB në mjedisin e testimit, duhet të gjeni linjën e mëposhtme:

export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"

Zëvendësojeni me:

export KAFKA_HEAP_OPTS="-Xmx256M -Xms128M"

Ruani një lënie:

:wq

4.4: Nisni serverin Kafka

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

Nëse gjithçka shkoi me sukses, do të shihni disa mesazhe në lidhje me statusin e serverit Kafka dhe i fundit do të lexojë:

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

Kjo do të thotë që ju keni nisur serverin Kafka.

4.5: Krijo një temë "test" në një lidhje të re SSH

Hapni një lidhje të re SSH, përdorni komandat e mëposhtme për të krijuar një temë "test":

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

Ju mund t'i shikoni temat tuaja me komandën e mëposhtme:

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

Në rastin tonë, dalja do të lexojë:

test

4.6: Prodhoni mesazhe duke përdorur temën "test"

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

Duke përdorur komandën e mësipërme, mund të futni çdo numër mesazhesh sipas dëshirës, ​​si p.sh.

Welcome aboard!
Bonjour!

Nëse merrni një gabim të ngjashëm me atë "WARN Error while fetching metadata with correlation id"gjatë futjes së një mesazhi, do t'ju duhet të përditësoni server.propertiesskedarin me informacionin e mëposhtëm:

port = 9092
advertised.host.name = localhost 

4.7: Shfaq mesazhet

Hapni një lidhje të tretë SSH dhe më pas ekzekutoni komandat e mëposhtme:

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

Ta-da! Mesazhet që keni prodhuar më parë do të shfaqen në lidhjen e tretë SSH. Sigurisht, nëse futni më shumë mesazhe nga lidhja e dytë SSH tani, do t'i shihni menjëherë në lidhjen e tretë SSH.

Më në fund, mund të shtypni Ctrl+C në çdo lidhje SSH për të ndaluar këto skripta.

Kjo eshte. Mund të mësoni më shumë rreth Apache Kafka në faqen zyrtare të internetit. Argëtohu!


Leave a Comment

Instaloni Plesk në CentOS 7

Instaloni Plesk në CentOS 7

Përdorimi i një sistemi të ndryshëm? Plesk është një panel kontrolli i pronarit të hostit në internet që lejon përdoruesit të administrojnë faqet e tyre të internetit personale dhe/ose të klientëve, bazat e të dhënave

Si të instaloni Squid Proxy në CentOS

Si të instaloni Squid Proxy në CentOS

Squid është një program i popullarizuar, falas Linux që ju lejon të krijoni një përfaqësues në ueb përcjellës. Në këtë udhëzues, do të shihni se si të instaloni Squid në CentOS për t'ju kthyer

Si të instaloni Lighttpd (LLMP Stack) në CentOS 6

Si të instaloni Lighttpd (LLMP Stack) në CentOS 6

Hyrje Lighttpd është një fork i Apache që synon të jetë shumë më pak intensiv me burime. Është i lehtë, prandaj emri i tij, dhe është mjaft i thjeshtë për t'u përdorur. Instaloni

Konfigurimi i rrjeteve statike dhe IPv6 në CentOS 7

Konfigurimi i rrjeteve statike dhe IPv6 në CentOS 7

VULTR kohët e fundit ka bërë ndryshime në fund të tyre dhe gjithçka duhet të funksionojë mirë tani me NetworkManager të aktivizuar. Nëse dëshironi të çaktivizoni

Modifikimi i Icinga2 për të përdorur Modelin Master/Klient në CentOS 6 ose CentOS 7

Modifikimi i Icinga2 për të përdorur Modelin Master/Klient në CentOS 6 ose CentOS 7

Icinga2 është një sistem i fuqishëm monitorimi dhe kur përdoret në një model master-klient, ai mund të zëvendësojë nevojën për kontrolle monitorimi të bazuara në NRPE. Master-klien

Si të instaloni Apache Cassandra 3.11.x në CentOS 7

Si të instaloni Apache Cassandra 3.11.x në CentOS 7

Përdorimi i një sistemi të ndryshëm? Apache Cassandra është një sistem i menaxhimit të bazës së të dhënave NoSQL falas dhe me burim të hapur që është krijuar për të ofruar shkallëzim, të lartë

Si të instaloni Microweber në CentOS 7

Si të instaloni Microweber në CentOS 7

Përdorimi i një sistemi të ndryshëm? Microweber është një CMS me burim të hapur drag and drop dhe dyqan online. Kodi burimor Microweber është pritur në GitHub. Ky udhëzues do t'ju tregojë

Si të instaloni Mattermost 4.1 në CentOS 7

Si të instaloni Mattermost 4.1 në CentOS 7

Përdorimi i një sistemi të ndryshëm? Mattermost është një alternativë me burim të hapur, të vetë-strehuar për shërbimin e mesazheve Slack SAAS. Me fjalë të tjera, me Mattermost, ju rreth

Le të enkriptojmë në Plesk

Le të enkriptojmë në Plesk

Paneli i kontrollit Plesk përmban një integrim shumë të bukur për Lets Encrypt. Lets Encrypt është një nga ofruesit e vetëm SSL që jep plotësisht certifikata

Lejon enkriptimin në cPanel

Lejon enkriptimin në cPanel

Lets Encrypt është një autoritet certifikimi i dedikuar për të ofruar certifikata SSL pa pagesë. cPanel ka ndërtuar një integrim të pastër në mënyrë që ju dhe klienti juaj

Si të instaloni Concrete5 në CentOS 7

Si të instaloni Concrete5 në CentOS 7

Përdorimi i një sistemi të ndryshëm? Concrete5 është një CMS me burim të hapur që ofron shumë veçori dalluese dhe të dobishme për të ndihmuar redaktorët në prodhimin e përmbajtjes me lehtësi dhe

How to Install Review Board on CentOS 7

How to Install Review Board on CentOS 7

Using a Different System? Review Board is a free and open source tool for reviewing source code, documentation, images and many more. It is web-based softwar

Konfiguro vërtetimin HTTP me Nginx në CentOS 7

Konfiguro vërtetimin HTTP me Nginx në CentOS 7

Në këtë udhëzues, do të mësoni se si të konfiguroni vërtetimin HTTP për një server ueb Nginx që funksionon në CentOS 7. Kërkesat Për të filluar, do t'ju duhet

Si të instaloni YOURLS në CentOS 7

Si të instaloni YOURLS në CentOS 7

YOURLS (Shkurtësi juaj i URL-së) është një aplikacion për shkurtimin e URL-ve me burim të hapur dhe analitikë të të dhënave. Në këtë artikull, ne do të mbulojmë procesin e instalimit

Si të instaloni dhe konfiguroni ArangoDB në CentOS 7

Si të instaloni dhe konfiguroni ArangoDB në CentOS 7

Përdorimi i një sistemi të ndryshëm? Hyrje ArangoDB është një bazë të dhënash NoSQL me burim të hapur me një model fleksibël të dhënash për dokumente, grafikë dhe vlera-kyçe. Eshte

Përdorimi i Etckeeper për kontrollin e versionit të /etc

Përdorimi i Etckeeper për kontrollin e versionit të /etc

Hyrje Drejtoria /etc/ luan një rol kritik në mënyrën se si funksionon një sistem Linux. Arsyeja për këtë është sepse pothuajse çdo konfigurim i sistemit

Pse duhet të përdorni SSHFS? Si të montoni një sistem skedari në distancë me SSHFS në CentOS 6

Pse duhet të përdorni SSHFS? Si të montoni një sistem skedari në distancë me SSHFS në CentOS 6

Shumë administratorë të sistemit menaxhojnë sasi të mëdha serverash. Kur skedarët duhet të aksesohen nëpër serverë të ndryshëm, hyni në secilin individualisht rreth

Vendosja e një serveri Half Life 2 në CentOS 6

Vendosja e një serveri Half Life 2 në CentOS 6

Ky tutorial do të mbulojë procesin e instalimit të një serveri lojërash Half Life 2 në Sistemin CentOS 6. Hapi 1: Instalimi i parakushteve Për të vendosur ou

Si të instaloni Laravel GitScrum në CentOS 7

Si të instaloni Laravel GitScrum në CentOS 7

Laravel GitScrum, ose GitScrum është një mjet produktiviteti me burim të hapur i krijuar për të ndihmuar ekipet e zhvillimit të zbatojnë metodologjinë Scrum në një mënyrë të ngjashme.

Si të instaloni PowerDNS në CentOS

Si të instaloni PowerDNS në CentOS

Hyrje Në këtë tutorial të Vultr, do të mësoni se si të instaloni PowerDNS. PowerDNS është një program për ekzekutimin e serverëve tuaj të emrave. Është shumë e dobishme kur

Ngritja e makinave: Aplikimet në botën reale të AI

Ngritja e makinave: Aplikimet në botën reale të AI

Inteligjenca Artificiale nuk është në të ardhmen, është këtu në të tashmen Në këtë blog Lexoni se si aplikacionet e inteligjencës artificiale kanë ndikuar në sektorë të ndryshëm.

Sulmet DDOS: Një përmbledhje e shkurtër

Sulmet DDOS: Një përmbledhje e shkurtër

A jeni edhe ju viktimë e Sulmeve DDOS dhe jeni konfuz në lidhje me metodat e parandalimit? Lexoni këtë artikull për të zgjidhur pyetjet tuaja.

A e keni pyetur ndonjëherë veten se si fitojnë para hakerët?

A e keni pyetur ndonjëherë veten se si fitojnë para hakerët?

Ju mund të keni dëgjuar se hakerët fitojnë shumë para, por a keni menduar ndonjëherë se si i fitojnë ato para? Le te diskutojme.

Shpikjet revolucionare nga Google që do tju bëjnë të lehtë jetën tuaj.

Shpikjet revolucionare nga Google që do tju bëjnë të lehtë jetën tuaj.

Dëshironi të shihni shpikjet revolucionare nga Google dhe se si këto shpikje ndryshuan jetën e çdo njeriu sot? Më pas lexoni në blog për të parë shpikjet nga Google.

E Premte Thelbësore: Çfarë ndodhi me Makinat e drejtuara nga AI?

E Premte Thelbësore: Çfarë ndodhi me Makinat e drejtuara nga AI?

Koncepti i makinave vetë-drejtuese për të dalë në rrugë me ndihmën e inteligjencës artificiale është një ëndërr që e kemi prej kohësh. Por, pavarësisht nga disa premtime, ato nuk shihen askund. Lexoni këtë blog për të mësuar më shumë…

Singulariteti teknologjik: Një e ardhme e largët e qytetërimit njerëzor?

Singulariteti teknologjik: Një e ardhme e largët e qytetërimit njerëzor?

Ndërsa Shkenca evoluon me një ritëm të shpejtë, duke marrë përsipër shumë nga përpjekjet tona, rriten edhe rreziqet për t'iu nënshtruar një Singulariteti të pashpjegueshëm. Lexoni, çfarë mund të thotë singulariteti për ne.

Evolucioni i ruajtjes së të dhënave - Infografik

Evolucioni i ruajtjes së të dhënave - Infografik

Metodat e ruajtjes së të dhënave kanë evoluar mund të jenë që nga lindja e të dhënave. Ky blog mbulon evolucionin e ruajtjes së të dhënave në bazë të një infografike.

Funksionalitetet e shtresave të arkitekturës së referencës së të dhënave të mëdha

Funksionalitetet e shtresave të arkitekturës së referencës së të dhënave të mëdha

Lexoni blogun për të njohur shtresat e ndryshme në arkitekturën e të dhënave të mëdha dhe funksionalitetet e tyre në mënyrën më të thjeshtë.

6 Përfitimet e mahnitshme të të pasurit pajisje shtëpiake inteligjente në jetën tonë

6 Përfitimet e mahnitshme të të pasurit pajisje shtëpiake inteligjente në jetën tonë

Në këtë botë të drejtuar nga dixhitali, pajisjet inteligjente të shtëpisë janë bërë një pjesë thelbësore e jetës. Këtu janë disa përfitime të mahnitshme të pajisjeve shtëpiake inteligjente se si ato e bëjnë jetën tonë të vlefshme dhe më të thjeshtë.

Përditësimi shtesë i macOS Catalina 10.15.4 po shkakton më shumë probleme sesa zgjidhja

Përditësimi shtesë i macOS Catalina 10.15.4 po shkakton më shumë probleme sesa zgjidhja

Së fundmi Apple lëshoi ​​macOS Catalina 10.15.4 një përditësim shtesë për të rregulluar problemet, por duket se përditësimi po shkakton më shumë probleme që çojnë në bricking të makinerive mac. Lexoni këtë artikull për të mësuar më shumë