Apache Kafkaga alustamine
Enne Apache Kafka installimist peab teil olema installitud Java ja sudo õigustega kasutajakonto. Lisaks on Kafka nõuetekohaseks tööks soovitatav omada 2 GB ja suuremat RAM-i.
Järgmised sammud juhendavad teid, kuidas Apache Kafka installida.
Java installimine
Kafka installimiseks on vaja Java. Kontrollige, kas teie Ubuntus on Java installitud, kontrollides versiooni järgmise käsuga:
$ java -- versioon
Kui Java pole installitud, kasutage Java OpenJDK installimiseks järgmisi käske.
$ sudo asjakohane installida default-jdk
Kasutajakonto loomine
Kui Java on juba installitud, looge mitte-root kasutajakonto. Peame andma talle ka mõned sudo-õigused, lisades kasutaja sudo rühma järgmise käsuga:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Logige sisse vastloodud kasutajakontole.
Kafka installimine
Peate ametlikult allalaadimislehelt alla laadima uusima Apache Kafka. Laadige selle binaarfailid alla, kasutades wget käsk, nagu on näidatud järgmises:
$ wget https: // downloads.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Kui binaarfail on alla laaditud, ekstraktige see, kasutades võtab käsk ja teisaldage ekstraktitud kataloog /opt/kafka.
Järgmisena looge süsteemsed skriptid jaoks Loomaaiatalitaja ja Kafka teenused, mis aitavad teenuseid käivitada ja peatada.
Kasutage süsteemsete skriptide loomiseks valitud redaktorit ja kleepige järgmine sisu. Alusta loomaaiapidajast:
$ sudo nano / jne / süsteemne / süsteem / loomaaiapidaja.teenusKleepige järgmine:
[ Üksus ]Kirjeldus =Apache Zookeeperi server
Dokumentatsioon =http: // zookeeper.apache.org
Vajab =network.target remote-fs.target
Pärast =network.target remote-fs.target
[ Teenindus ]
Tüüp =lihtne
ExecStart = / opt / kafka / prügikast / zookeeper-server-start.sh / opt / kafka / konfig / loomaaiapidaja.omadused
ExecStop = / opt / kafka / prügikast / zookeeper-server-stop.sh
Taaskäivita =ebanormaalne
[ Installige ]
WantedBy =multi-user.target
Salvestage fail. Looge Kafka jaoks süsteemne fail ja kleepige järgmine sisu:
Kleepimisel veenduge, et määrasite oma süsteemi installitud Java jaoks õige tee.
[ Üksus ]Kirjeldus =Apache Kafka server
Dokumentatsioon =http: // kafka.apache.org / documentation.html
Vajab =loomaaiapidaja.teenus
[ Teenindus ]
Tüüp =lihtne
Keskkond = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / opt / kafka / prügikast / kafka-server-start.sh / opt / kafka / konfig / server.properties
ExecStop = / opt / kafka / prügikast / kafka-server-stop.sh
Taaskäivita =ebanormaalne
[ Installige ]
WantedBy =multi-user.target
Kui olete valmis, rakendage muudatused, laadides uuesti systemd deemon:
Järgmisena lubage teenus Zookeeper ja käivitage see järgmiste käskude abil:
$ sudo systemctl käivita zookeepe < tugev > r tugev >
Kafka puhul peate tegema sama:
$ sudo systemctl start kafka
Pärast teenuste käivitamist saate enne Kafkas teema loomist kontrollida nende olekut.
Kafka hea asi on see, et saate kasutada mitut skripti.
Teeme uue teema nimega linuxhint1 kasutades kafka-topics.sh skript ühe partitsiooni ja replikatsiooniga. Kasutage järgmist käsku:
$ sudo -sisse linuxhint / opt / kafka / prügikast / kafka-topics.sh -- luua --bootstrap-server localhost: 9092 --replikatsioonitegur 1 -- vaheseinad 1 --teema linuxhint1 
Pange tähele, et meie teema on loodud. Selle kontrollimiseks näeme eelmist sõnumit.
Teise võimalusena saate saadaolevad teemad loendisse, kasutades -loend suvand järgmises käsus. See peaks tagastama meie loodud teema:S
$ sudo -sisse linuxhint / opt / kafka / prügikast / kafka-topics.sh --loend --bootstrap-server localhost: 9092 
Kafka teema loomisel saate alustada voogude andmete kirjutamist Kafka-konsool-producer.sh ja kontrollige, kas see kajastub teie puhul tarbija.sh.
Avage oma kest ja pääsete juurde teemale, mille lõime faili producer.sh abil, nagu on näidatud järgmiselt:
$ sudo -sisse linuxhint / opt / kafka / prügikast / kafka-console-producer.sh --maaklerinimekiri localhost: 9092 --teema linuxhint1 
Järgmisena avage teine kest ja avage Consummer.sh abil Kafka teema.
Kui kaks kesta on avatud, saate tootjakonsoolil sõnumeid saata. Mida iganes sisestate, kajastub tarbijakonsool, mis kinnitab, et meie Apache Kafka on valmis ja töötab.
Järeldus
Selle juhendi abil on teil nüüd kõik sammud, mida saate järgida Apache Kafka installimiseks oma Ubuntu 22.04. Loodetavasti õnnestus teil järgida iga sammu ja installida oma Apache Kafka ning luua teemasid lihtsa tarbija- ja tootjatoodangu käivitamiseks. Sama saate rakendada ka suurtootmises.