Početak rada s Apache Kafkom
Prije instaliranja Apache Kafke, morate imati instaliranu Javu i korisnički račun sa sudo privilegijama. Štoviše, preporuča se imati RAM od 2 GB i više za pravilno pokretanje Kafke.
Sljedeći koraci će vas voditi kako instalirati Apache Kafka.
Instaliranje Jave
Java je potrebna za instalaciju Kafke. Provjerite ima li vaš Ubuntu instaliranu Javu provjerom verzije pomoću sljedeće naredbe:
$ Java --verzija
Ako Java nije instalirana, koristite sljedeće naredbe za instaliranje Java OpenJDK.
$ sudo prikladan instalirati zadani-jdk
Stvaranje korisničkog računa
Uz već instaliranu Javu, stvorite nekorijenski korisnički račun. Također mu moramo dati neke sudo privilegije dodavanjem korisnika u sudo grupu pomoću sljedeće naredbe:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Prijavite se na novostvoreni korisnički račun.
Instaliranje Kafke
Morate preuzeti najnoviji Apache Kafka sa službene stranice za preuzimanje. Preuzmite njegove binarne datoteke pomoću wget naredba kao što je prikazano u nastavku:
$ wget https: // preuzimanja.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Nakon što se binarna datoteka preuzme, izdvojite je pomoću uzima naredbu i premjestite izdvojeni direktorij u /opt/kafka.
Zatim stvorite systemd skripte za Čuvar zoo vrta i Kafka usluge koje pomažu u pokretanju i zaustavljanju usluga.
Upotrijebite uređivač po izboru za stvaranje systemd skripti i zalijepite sljedeći sadržaj. Započnite s Zookeeperom:
$ sudo nano / itd / systemd / sustav / čuvar zoološkog vrta.servisZalijepite sljedeće:
[ Jedinica ]Opis = Apache Zookeeper poslužitelj
Dokumentacija =http: // zookeeper.apache.org
Zahtijeva =network.target udaljeni-fs.target
Nakon =network.target udaljeni-fs.target
[ Servis ]
Tip =jednostavno
ExecStart = / opt / kafka / kanta za smeće / zookeeper-server-start.sh / opt / kafka / konfiguracija / čuvar zoološkog vrta.svojstva
ExecStop = / opt / kafka / kanta za smeće / zookeeper-server-stop.sh
Ponovno pokretanje =na-nenormalan
[ Instalirati ]
WantedBy =multi-user.target
Spremite datoteku. Napravite systemd datoteku za Kafku i zalijepite sljedeći sadržaj:
Prilikom lijepljenja provjerite jeste li postavili ispravnu stazu za Javu koju ste instalirali u svoj sustav.
[ Jedinica ]Opis = Apache Kafka poslužitelj
Dokumentacija =http: // kafka.apache.org / dokumentacija.html
Zahtijeva =čuvar.usluga
[ Servis ]
Tip =jednostavno
Okoliš = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / opt / kafka / kanta za smeće / kafka-server-start.sh / opt / kafka / konfiguracija / poslužitelj.svojstva
ExecStop = / opt / kafka / kanta za smeće / kafka-server-stop.sh
Ponovno pokretanje =na-nenormalan
[ Instalirati ]
WantedBy =multi-user.target
Kada završite, primijenite promjene ponovnim učitavanjem systemd demona:
Zatim omogućite uslugu Zookeeper i pokrenite je pomoću sljedećih naredbi:
$ sudo systemctl pokrenite zookeepe < snažna > r snažna >
Također trebate učiniti isto za Kafku:
$ sudo systemctl pokretanje kafke
Nakon što pokrenete usluge, možete provjeriti njihov status prije nego što stvorimo temu u Kafki.
Dobra stvar kod Kafke je što postoji više skripti koje možete koristiti.
Kreirajmo novu temu pod nazivom linuxhint1 koristiti kafka-teme.sh skripta s jednom particijom i replikacijom. Koristite sljedeću naredbu:
$ sudo -u linuxhint / opt / kafka / kanta za smeće / kafka-teme.sh --stvoriti --bootstrap-poslužitelj lokalni domaćin: 9092 --faktor replikacije 1 -- particije 1 --tema linuxhint1 
Imajte na umu da je naša tema stvorena. Možemo vidjeti prethodnu poruku da to potvrdimo.
Alternativno, možete ispisati dostupne teme pomoću -popis opciju u sljedećoj naredbi. Trebao bi vratiti temu koju smo kreirali: S
$ sudo -u linuxhint / opt / kafka / kanta za smeće / kafka-teme.sh --popis --bootstrap-poslužitelj lokalni domaćin: 9092 
S Kafka temom koja se stvara, možete početi pisati podatke o tokovima na Kafka-console-producer.sh i provjerite odražava li se na vašem potrošač.š.
Otvorite svoju ljusku i pristupite temi koju smo stvorili pomoću producer.sh kao što je prikazano u nastavku:
$ sudo -u linuxhint / opt / kafka / kanta za smeće / kafka-console-producer.sh --broker-list lokalni domaćin: 9092 --tema linuxhint1 
Zatim otvorite drugu ljusku i pristupite Kafkinoj temi koristeći potrošač.sh.
S dvije otvorene školjke možete slati poruke na producentskoj konzoli. Što god upišete, odražava se na potrošačkoj konzoli potvrđujući da je naš Apache Kafka spreman i radi.
Zaključak
S ovim vodičem sada imate sve korake koje možete slijediti kako biste instalirali Apache Kafka u svoj Ubuntu 22.04. Nadamo se da ste uspjeli pratiti svaki korak i instalirati svoj Apache Kafka i stvoriti teme za pokretanje jednostavne potrošačke i proizvođačke proizvodnje. Isto možete implementirati u velikoj proizvodnji.