Kako začeti z Apache Kafko
Preden namestite Apache Kafka, morate imeti nameščeno Javo in uporabniški račun s privilegiji sudo. Poleg tega je priporočljivo imeti RAM 2 GB ali več za pravilno delovanje Kafke.
Naslednji koraki vas bodo vodili pri namestitvi Apache Kafka.
Namestitev Jave
Za namestitev Kafke je potrebna Java. Preverite, ali ima vaš Ubuntu nameščeno Javo, tako da preverite različico z naslednjim ukazom:
$ java --različica
Če Java ni nameščena, uporabite naslednje ukaze za namestitev Java OpenJDK.
$ sudo apt namestite privzeto-jdk
Ustvarjanje uporabniškega računa
Ko je Java že nameščena, ustvarite nekorenski uporabniški račun. Prav tako mu moramo dati nekaj privilegijev sudo, tako da uporabnika dodamo v skupino sudo z naslednjim ukazom:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Prijavite se v novo ustvarjeni uporabniški račun.
Namestitev Kafke
Najnovejšo različico Apache Kafka morate prenesti z uradne strani za prenos. Prenesite njegove binarne datoteke z uporabo wget ukaz, kot je prikazano v nadaljevanju:
$ wget https: // downloads.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Ko je binarna datoteka prenesena, jo ekstrahirajte z uporabo vzame in premaknite ekstrahirani imenik v /opt/kafka.
Nato ustvarite skripte systemd za Oskrbnik živalskega vrta in Kafka storitve, ki pomagajo pri zagonu in zaustavitvi storitev.
Uporabite urejevalnik po izbiri, da ustvarite skripte systemd in prilepite naslednjo vsebino. Začnite z Zookeeperjem:
$ sudo nano / itd / systemd / sistem / oskrbnik.storitevPrilepite naslednje:
[ Enota ]Opis =Strežnik Apache Zookeeper
Dokumentacija =http: // zookeeper.apache.org
Zahteva =network.target oddaljeni-fs.target
Po =network.target oddaljeni-fs.target
[ Storitev ]
Vrsta =preprosto
ExecStart = / opt / kafka / koš / zookeeper-server-start.sh / opt / kafka / konfiguracija / zookeeper.properties
ExecStop = / opt / kafka / koš / zookeeper-server-stop.sh
Ponovni zagon =na-nenormalno
[ Namestite ]
WantedBy =multi-user.target
Shranite datoteko. Ustvarite datoteko systemd za Kafko in prilepite naslednjo vsebino:
Pri lepljenju se prepričajte, da ste nastavili pravo pot za Javo, ki ste jo namestili v sistem.
[ Enota ]Opis =strežnik Apache Kafka
Dokumentacija =http: // kafka.apache.org / dokumentacija.html
Zahteva =zookeeper.service
[ Storitev ]
Vrsta =preprosto
okolje = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / opt / kafka / koš / kafka-server-start.sh / opt / kafka / konfiguracija / server.properties
ExecStop = / opt / kafka / koš / kafka-server-stop.sh
Ponovni zagon =na-nenormalno
[ Namestite ]
WantedBy =multi-user.target
Ko končate, uporabite spremembe tako, da ponovno naložite demon systemd:
Nato omogočite storitev Zookeeper in jo zaženite z naslednjimi ukazi:
$ sudo systemctl zaženi zookeepe < močan > r močan >
Enako morate storiti tudi za Kafko:
$ sudo systemctl zagon kafke
Ko zaženete storitve, lahko preverite njihov status, preden ustvarimo temo v Kafki.
Dobra stvar pri Kafki je, da obstaja več skriptov, ki jih lahko uporabite.
Ustvarimo novo temo z imenom linuxhint1 uporabljati kafka-topics.sh skript z eno particijo in replikacijo. Uporabite naslednji ukaz:
$ sudo -in linuxhint / opt / kafka / koš / kafka-topics.sh --ustvariti --bootstrap-strežnik lokalni gostitelj: 9092 --replikacijski faktor 1 --predelne stene 1 --tema linuxhint1 
Upoštevajte, da je naša tema ustvarjena. Ogledamo si lahko prejšnje sporočilo, da to potrdimo.
Lahko pa navedete razpoložljive teme z uporabo – seznam možnost v naslednjem ukazu. Vrniti bi moralo temo, ki smo jo ustvarili: S
$ sudo -in linuxhint / opt / kafka / koš / kafka-topics.sh --seznam --bootstrap-strežnik lokalni gostitelj: 9092 
Ko se ustvarja tema Kafka, lahko začnete pisati podatke o tokovih na Kafka-console-producer.sh in preverite, ali se odraža v vašem potrošnik.sh.
Odprite lupino in dostopajte do teme, ki smo jo ustvarili z uporabo producer.sh, kot je prikazano spodaj:
$ sudo -in linuxhint / opt / kafka / koš / kafka-console-producer.sh --broker-seznam lokalni gostitelj: 9092 --tema linuxhint1 
Nato odprite drugo ukazno lupino in dostopajte do teme Kafka z uporabo consumer.sh.
Ko sta lupini odprti, lahko pošiljate sporočila na konzoli producenta. Karkoli vnesete, se odraža v uporabniški konzoli in potrjuje, da je naš Apache Kafka pripravljen in deluje.
Zaključek
S tem priročnikom imate zdaj na voljo vse korake, ki jih lahko izvedete za namestitev Apache Kafka v svoj Ubuntu 22.04. Upajmo, da vam je uspelo slediti vsakemu koraku in namestiti svoj Apache Kafka ter ustvariti teme za zagon preproste produkcije potrošnikov in proizvajalcev. Enako lahko izvedete v veliki proizvodnji.