Darbo su Apache Kafka pradžia
Prieš diegdami Apache Kafka, turite turėti įdiegtą Java ir vartotojo abonementą su sudo privilegijomis. Be to, norint tinkamai veikti „Kafka“, rekomenduojama turėti 2 GB ir daugiau RAM.
Šie veiksmai padės jums įdiegti „Apache Kafka“.
„Java“ diegimas
Norint įdiegti „Kafka“, reikalinga „Java“. Patikrinkite, ar jūsų Ubuntu įdiegta „Java“, patikrindami versiją naudodami šią komandą:
$ java -- versija
Jei Java neįdiegta, naudokite šias komandas, kad įdiegtumėte Java OpenJDK.
$ sudo apt diegti default-jdk
Vartotojo paskyros sukūrimas
Kai „Java“ jau įdiegta, sukurkite ne root vartotojo abonementą. Taip pat turime suteikti jai keletą sudo privilegijų, įtraukdami vartotoją į sudo grupę naudodami šią komandą:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Prisijunkite prie naujai sukurtos vartotojo paskyros.
Kafka diegimas
Turite atsisiųsti naujausią „Apache Kafka“ versiją iš oficialaus atsisiuntimo puslapio. Atsisiųskite dvejetainius failus naudodami wget komandą, kaip parodyta toliau:
$ wget https: // downloads.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Atsisiuntę dvejetainį failą, ištraukite jį naudodami paima komandą ir perkelkite ištrauktą katalogą į /opt/kafka.
Tada sukurkite sisteminiai scenarijai už Zoologijos sodo prižiūrėtojas ir Kafka paslaugos, kurios padeda pradėti ir sustabdyti paslaugas.
Naudokite pasirinktą redaktorių, kad sukurtumėte sisteminius scenarijus ir įklijuokite toliau pateiktą turinį. Pradėkite nuo zoologijos sodo prižiūrėtojo:
$ sudo nano / ir tt / sisteminis / sistema / zoologijos sodo prižiūrėtojas.tarnybaĮklijuokite šiuos dalykus:
[ Vienetas ]apibūdinimas =Apache Zookeeper serveris
Dokumentacija =http: // zookeeper.apache.org
Reikalauja =network.target remote-fs.target
Po to =network.target remote-fs.target
[ Aptarnavimas ]
Tipas = paprasta
ExecStart = / opt / kafka / šiukšliadėžė / zookeeper-server-start.sh / opt / kafka / konfig / zoologijos sodo prižiūrėtojas.ypatybės
ExecStop = / opt / kafka / šiukšliadėžė / zookeeper-server-stop.sh
Perkrauti =nenormalus
[ Diegti ]
WantedBy =multi-user.target
Išsaugokite failą. Sukurkite Kafkos sistemos failą ir įklijuokite šį turinį:
Įklijuodami įsitikinkite, kad nustatėte teisingą „Java“, kurią įdiegėte savo sistemoje, kelią.
[ Vienetas ]apibūdinimas = Apache Kafka serveris
Dokumentacija =http: // kafka.apache.org / documentation.html
Reikalauja =zoologijos sodo prižiūrėtojas.paslauga
[ Aptarnavimas ]
Tipas = paprasta
Aplinka = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / opt / kafka / šiukšliadėžė / kafka-server-start.sh / opt / kafka / konfig / serveris.ypatybės
ExecStop = / opt / kafka / šiukšliadėžė / kafka-server-stop.sh
Perkrauti =nenormalus
[ Diegti ]
WantedBy =multi-user.target
Baigę pritaikykite pakeitimus iš naujo įkeldami sistemos demoną:
Tada įjunkite „Zookeeper“ paslaugą ir paleiskite ją naudodami šias komandas:
$ sudo systemctl start zookeepe < stiprus > r stiprus >
Tą patį turite padaryti ir su Kafka:
$ sudo systemctl start kafka
Pradėję teikti paslaugas galite patikrinti jų būseną prieš kurdami temą Kafkoje.
„Kafka“ geras dalykas yra tai, kad yra keli scenarijai, kuriuos galite naudoti.
Sukurkime naują temą pavadinimu linuxhint1 naudojant kafka-topics.sh scenarijus su vienu skaidiniu ir replikacija. Naudokite šią komandą:
$ sudo -į linuxhint / opt / kafka / šiukšliadėžė / kafka-topics.sh --kurti --bootstrap-server localhost: 9092 --replikacijos faktorius 1 -- pertvaros 1 --tema linuxhint1 
Atminkite, kad mūsų tema sukurta. Kad tai patvirtintume, matome ankstesnį pranešimą.
Arba galite išvardyti galimas temas naudodami – sąrašas parinktis šioje komandoje. Tai turėtų grąžinti temą, kurią sukūrėme:S
$ sudo -į linuxhint / opt / kafka / šiukšliadėžė / kafka-topics.sh -- sąrašas --bootstrap-server localhost: 9092 
Sukūrę Kafkos temą, galite pradėti rašyti srautų duomenis Kafka-console-producer.sh ir patikrinkite, ar tai atsispindi jūsų vartotojas.sh.
Atidarykite apvalkalą ir pasiekite temą, kurią sukūrėme naudodami producer.sh, kaip parodyta toliau:
$ sudo -į linuxhint / opt / kafka / šiukšliadėžė / kafka-console-producer.sh -- brokerių sąrašas localhost: 9092 --tema linuxhint1 
Tada atidarykite kitą apvalkalą ir pasiekite Kafka temą naudodami Consumer.sh.
Atidarę du apvalkalus, galite siųsti pranešimus gamintojo pulte. Kad ir ką įvestumėte, tai atsispindi vartotojų pulte ir patvirtina, kad mūsų „Apache Kafka“ veikia ir veikia.
Išvada
Naudodami šį vadovą dabar turite visus veiksmus, kuriuos galite atlikti norėdami įdiegti „Apache Kafka“ savo Ubuntu 22.04. Tikimės, kad jums pavyko atlikti kiekvieną žingsnį ir įdiegti „Apache Kafka“ bei sukurti temas, kad galėtumėte vykdyti paprastą vartotojų ir gamintojų gamybą. Tą patį galite įgyvendinti didelėje gamyboje.