Začíname s Apache Kafka
Pred inštaláciou Apache Kafka musíte mať nainštalovanú Javu a používateľský účet s oprávneniami sudo. Okrem toho sa pre správne fungovanie Kafky odporúča mať RAM 2 GB a viac.
Nasledujúce kroky vás prevedú, ako nainštalovať Apache Kafka.
Inštalácia Java
Na inštaláciu Kafka je potrebná Java. Skontrolujte, či má váš Ubuntu nainštalovanú Javu tak, že skontrolujete verziu pomocou nasledujúceho príkazu:
$ java --verzia
Ak Java nie je nainštalovaná, na inštaláciu Java OpenJDK použite nasledujúce príkazy.
$ sudo apt Inštalácia default-jdk
Vytvorenie používateľského účtu
S už nainštalovanou Java vytvorte používateľské konto typu non-root. Musíme mu tiež dať nejaké privilégiá sudo pridaním používateľa do skupiny sudo pomocou nasledujúceho príkazu:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Prihláste sa do novovytvoreného používateľského účtu.
Inštalácia Kafku
Najnovšiu verziu Apache Kafka si musíte stiahnuť z oficiálnej stránky na stiahnutie. Stiahnite si jeho binárne súbory pomocou wget príkaz, ako je znázornené v nasledujúcom:
$ wget https: // downloads.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Po stiahnutí binárneho súboru ho extrahujte pomocou berie a presuňte extrahovaný adresár do /opt/kafka.
Ďalej vytvorte systémové skripty pre Ošetrovateľ v zoo a Kafka služby, ktoré pomáhajú pri spúšťaní a zastavovaní služieb.
Použite editor podľa vlastného výberu na vytvorenie skriptov systemd a prilepte nasledujúci obsah. Začnite so správcom zoo:
$ sudo nano / atď / systemd / systém / zookeeper.servisPrilepte nasledovné:
[ Jednotka ]Popis =Server Apache Zookeeper
Dokumentácia =http: // zookeeper.apache.org
Vyžaduje =network.target remote-fs.target
Po =network.target remote-fs.target
[ servis ]
Typ =jednoduché
ExecStart = / opt / kafka / kôš / zookeeper-server-start.sh / opt / kafka / config / zookeeper.vlastnosti
ExecStop = / opt / kafka / kôš / zookeeper-server-stop.sh
Reštart =on-abnormálne
[ Inštalácia ]
WantedBy =multi-user.target
Uložte súbor. Vytvorte súbor systemd pre Kafka a vložte nasledujúci obsah:
Pri vkladaní sa uistite, že ste nastavili správnu cestu pre Javu, ktorú máte nainštalovanú vo svojom systéme.
[ Jednotka ]Popis = Server Apache Kafka
Dokumentácia =http: // kafka.apache.org / dokumentácia.html
Vyžaduje =zookeeper.service
[ servis ]
Typ =jednoduché
Životné prostredie = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / opt / kafka / kôš / kafka-server-start.sh / opt / kafka / config / server.properties
ExecStop = / opt / kafka / kôš / kafka-server-stop.sh
Reštart =on-abnormálne
[ Inštalácia ]
WantedBy =multi-user.target
Po dokončení použite zmeny opätovným načítaním démona systemd:
Ďalej povoľte službu Zookeeper a spustite ju pomocou nasledujúcich príkazov:
$ sudo systemctl spustenie zookeepe < silný > r silný >
To isté musíte urobiť aj pre Kafku:
$ sudo systemctl štart kafka
Po spustení služieb si môžete overiť ich stav predtým, ako vytvoríme tému v Kafke.
Dobrá vec na Kafkovi je, že existuje viacero skriptov, ktoré môžete použiť.
Vytvorme novú tému s názvom linuxhint1 pomocou kafka-topics.sh skript s jedným oddielom a replikáciou. Použite nasledujúci príkaz:
$ sudo -v linuxhint / opt / kafka / kôš / kafka-topics.sh --vytvoriť --bootstrap-server localhost: 9092 --replikačný-faktor 1 -- priečky 1 --téma linuxhint1 
Všimnite si, že naša téma je vytvorená. Môžeme vidieť predchádzajúcu správu, aby sme si to overili.
Prípadne môžete zobraziť zoznam dostupných tém pomocou – zoznam možnosť v nasledujúcom príkaze. Mala by vrátiť tému, ktorú sme vytvorili:S
$ sudo -v linuxhint / opt / kafka / kôš / kafka-topics.sh --zoznam --bootstrap-server localhost: 9092 
Po vytvorení témy Kafka môžete začať písať údaje o streamoch na Kafka-console-producer.sh a skontrolujte, či sa to odráža vo vašom spotrebiteľ.sh.
Otvorte svoj shell a prejdite k téme, ktorú sme vytvorili pomocou producenta.sh, ako je uvedené nižšie:
$ sudo -v linuxhint / opt / kafka / kôš / kafka-console-producer.sh --zoznam-sprostredkovateľov localhost: 9092 --téma linuxhint1 
Potom otvorte ďalší shell a prejdite na tému Kafka pomocou Consumer.sh.
Po otvorení dvoch škrupín môžete odoslať správu na konzole výrobcu. Čokoľvek napíšete, sa odrazí v spotrebiteľskej konzole, ktorá potvrdí, že náš Apache Kafka je v prevádzke.
Záver
Pomocou tejto príručky teraz máte všetky kroky, ktoré môžete vykonať pri inštalácii Apache Kafka vo vašom Ubuntu 22.04. Dúfajme, že sa vám podarilo sledovať každý krok a nainštalovať Apache Kafka a vytvoriť témy na spustenie jednoduchej výroby pre spotrebiteľov a výrobcov. To isté môžete implementovať vo veľkej produkcii.