Darba sākšana ar Apache Kafka
Pirms Apache Kafka instalēšanas jums ir jābūt instalētai Java un lietotāja kontam ar sudo privilēģijām. Turklāt, lai Kafka darbotos pareizi, ieteicams izmantot 2 GB un lielāku RAM.
Tālāk norādītās darbības palīdzēs jums instalēt Apache Kafka.
Java instalēšana
Lai instalētu Kafka, ir nepieciešama Java. Pārbaudiet, vai jūsu Ubuntu ir instalēta Java, pārbaudot versiju, izmantojot šo komandu:
$ java -- versija
Ja Java nav instalēta, izmantojiet tālāk norādītās komandas, lai instalētu Java OpenJDK.
$ sudo apt uzstādīt noklusējuma-jdk
Lietotāja konta izveide
Ja Java jau ir instalēta, izveidojiet lietotāja kontu, kas nav saknes lietotājs. Mums ir arī jāpiešķir tai dažas sudo privilēģijas, pievienojot lietotāju sudo grupai, izmantojot šādu komandu:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Piesakieties jaunizveidotajā lietotāja kontā.
Kafkas instalēšana
Jums ir jālejupielādē jaunākā Apache Kafka versija no oficiālās lejupielādes lapas. Lejupielādējiet tā bināros failus, izmantojot wget komandu, kā parādīts tālāk:
$ wget https: // downloads.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Kad binārais fails ir lejupielādēts, izņemiet to, izmantojot ņem komandu un pārvietojiet izvilkto direktoriju uz /opt/kafka.
Pēc tam izveidojiet sistēmiskie skripti priekš Zoodārza sargs un Kafka pakalpojumi, kas palīdz sākt un apturēt pakalpojumus.
Izmantojiet izvēlēto redaktoru, lai izveidotu sistēmas skriptus un ielīmētu tālāk norādīto saturu. Sāciet ar Zookeeper:
$ sudo nano / utt / systemd / sistēma / zookeeper.serviceIelīmējiet šo:
[ Vienība ]Apraksts =Apache Zookeeper serveris
Dokumentācija =http: // zookeeper.apache.org
Nepieciešams =network.target remote-fs.target
Pēc =network.target remote-fs.target
[ apkalpošana ]
Tips = vienkārši
ExecStart = / izvēlēties / kafka / atkritumu tvertne / zookeeper-server-start.sh / izvēlēties / kafka / konfigurācija / zoodārznieks.īpašības
ExecStop = / izvēlēties / kafka / atkritumu tvertne / zookeeper-server-stop.sh
Restartēt =par-nenormāli
[ Uzstādīt ]
WantedBy =vairāku lietotāju.mērķis
Saglabājiet failu. Izveidojiet Kafka sistēmas failu un ielīmējiet šādu saturu:
Ielīmējot, pārliecinieties, vai esat iestatījis pareizo ceļu Java, kuru instalējāt savā sistēmā.
[ Vienība ]Apraksts =Apache Kafka serveris
Dokumentācija =http: // kafka.apache.org / documentation.html
Nepieciešams =zoodārznieks.pakalpojums
[ apkalpošana ]
Tips = vienkārši
Vide = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / izvēlēties / kafka / atkritumu tvertne / kafka-server-start.sh / izvēlēties / kafka / konfigurācija / server.properties
ExecStop = / izvēlēties / kafka / atkritumu tvertne / kafka-server-stop.sh
Restartēt =par-nenormāli
[ Uzstādīt ]
WantedBy =vairāku lietotāju.mērķis
Kad tas ir izdarīts, piemērojiet izmaiņas, atkārtoti ielādējot systemd dēmonu:
Pēc tam iespējojiet pakalpojumu Zookeeper un palaidiet to, izmantojot šādas komandas:
$ sudo systemctl start zookeepe < stiprs > r stiprs >
Tas pats jādara arī Kafka:
$ sudo systemctl start kafka
Kad sākat pakalpojumus, varat pārbaudīt to statusu, pirms mēs izveidojam tēmu Kafkā.
Kafka labā lieta ir tā, ka varat izmantot vairākus skriptus.
Izveidosim jaunu tēmu ar nosaukumu linuxhint1 izmantojot kafka-topics.sh skripts ar vienu nodalījumu un replikāciju. Izmantojiet šādu komandu:
$ sudo -in linuxhint / izvēlēties / kafka / atkritumu tvertne / kafka-topics.sh -- izveidot --bootstrap-serveris localhost: 9092 --replicēšanas faktors 1 -- starpsienas 1 --temats linuxhint1 
Ņemiet vērā, ka mūsu tēma ir izveidota. Mēs varam redzēt iepriekšējo ziņojumu, lai to pārbaudītu.
Varat arī uzskaitīt pieejamās tēmas, izmantojot - saraksts opciju nākamajā komandā. Tam jāatgriež tēma, ko izveidojām:S
$ sudo -in linuxhint / izvēlēties / kafka / atkritumu tvertne / kafka-topics.sh -- saraksts --bootstrap-serveris localhost: 9092 
Kad Kafka tēma tiek izveidota, varat sākt rakstīt straumju datus uz Kafka-console-producer.sh un pārbaudiet, vai tas atspoguļojas jūsu patērētājs.sh.
Atveriet čaulu un piekļūstiet tēmai, ko izveidojām, izmantojot producentu.sh, kā parādīts tālāk.
$ sudo -in linuxhint / izvēlēties / kafka / atkritumu tvertne / kafka-console-producer.sh -- brokeru saraksts localhost: 9092 --temats linuxhint1 
Pēc tam atveriet citu čaulu un piekļūstiet Kafka tēmai, izmantojot consumer.sh.
Kad divi apvalki ir atvērti, varat nosūtīt ziņojumus producenta konsolē. Neatkarīgi no tā, ko rakstāt, tas tiek atspoguļots patērētāju konsolē, apstiprinot, ka mūsu Apache Kafka ir izveidota un darbojas.
Secinājums
Izmantojot šo rokasgrāmatu, jums tagad ir visas darbības, kuras varat veikt, lai instalētu Apache Kafka savā Ubuntu 22.04. Cerams, ka jums izdevās izpildīt katru darbību un instalēt savu Apache Kafka un izveidot tēmas, lai palaistu vienkāršu patērētāju un ražotāju produkciju. To pašu var īstenot lielajā ražošanā.