Apache Kafkan käytön aloittaminen
Ennen kuin asennat Apache Kafkan, sinulla on oltava Java asennettuna ja käyttäjätili, jolla on sudo-oikeudet. Lisäksi on suositeltavaa, että RAM-muisti on vähintään 2 Gt, jotta Kafka toimii oikein.
Seuraavat vaiheet opastavat sinua Apache Kafkan asentamisessa.
Javan asentaminen
Kafkan asentamiseen tarvitaan Java. Tarkista, onko Ubuntussa asennettuna Java, tarkistamalla versio seuraavalla komennolla:
$ java --versio
Jos Javaa ei ole asennettu, käytä seuraavia komentoja Java OpenJDK:n asentamiseen.
$ sudo apt Asentaa oletus-jdk
Käyttäjätilin luominen
Kun Java on jo asennettu, luo ei-root-käyttäjätili. Meidän on myös annettava sille joitain sudo-oikeuksia lisäämällä käyttäjä sudo-ryhmään seuraavalla komennolla:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Kirjaudu sisään äskettäin luotuun käyttäjätiliin.
Kafkan asennus
Sinun on ladattava uusin Apache Kafka viralliselta lataussivulta. Lataa sen binaaritiedostot käyttämällä wget komento seuraavan kuvan mukaisesti:
$ wget https: // downloads.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Kun binaaritiedosto on ladattu, pura se käyttämällä ottaa komento ja siirrä purettu hakemisto hakemistoon /opt/kafka.
Luo seuraavaksi systemd-skriptit varten Eläintarhanhoitaja ja Kafka palvelut, jotka auttavat palvelujen käynnistämisessä ja lopettamisessa.
Käytä valitsemaasi editoria luodaksesi systemd-skriptit ja liitä seuraava sisältö. Aloita eläintarhanhoitajasta:
$ sudo nano / jne / systemd / järjestelmä / eläintarhanhoitaja.palveluLiitä seuraavat:
[ Yksikkö ]Kuvaus =Apache Zookeeper -palvelin
Dokumentointi =http: // zookeeper.apache.org
Vaatii =network.target remote-fs.target
Jälkeen =network.target remote-fs.target
[ Palvelu ]
Tyyppi = yksinkertainen
ExecStart = / valita / kafka / roskakori / zookeeper-server-start.sh / valita / kafka / config / eläintarhanhoitaja.ominaisuudet
ExecStop = / valita / kafka / roskakori / zookeeper-server-stop.sh
Uudelleenkäynnistää = epänormaali
[ Asentaa ]
WantedBy =multi-user.target
Tallenna tiedosto. Luo Systemd-tiedosto Kafkalle ja liitä seuraava sisältö:
Kun liität, varmista, että asetat oikean polun järjestelmääsi asentamallesi Javalle.
[ Yksikkö ]Kuvaus =Apache Kafka -palvelin
Dokumentointi =http: // kafka.apache.org / documentation.html
Vaatii =eläintarhanhoitaja.palvelu
[ Palvelu ]
Tyyppi = yksinkertainen
Ympäristö = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / valita / kafka / roskakori / kafka-server-start.sh / valita / kafka / config / server.properties
ExecStop = / valita / kafka / roskakori / kafka-server-stop.sh
Uudelleenkäynnistää = epänormaali
[ Asentaa ]
WantedBy =multi-user.target
Kun olet valmis, ota muutokset käyttöön lataamalla systemd-daemon uudelleen:
Ota seuraavaksi Zookeeper-palvelu käyttöön ja käynnistä se seuraavilla komennoilla:
$ sudo systemctl käynnistä zookeepe < vahva > r vahva >
Sinun on tehtävä sama myös Kafkalle:
$ sudo systemctl start kafka
Kun aloitat palvelut, voit tarkistaa niiden tilan ennen kuin luomme aiheen Kafkaan.
Kafkan hyvä puoli on, että voit käyttää useita skriptejä.
Luodaan uusi aihe nimeltä linuxhint1 käyttämällä kafka-topics.sh komentosarja, jossa on yksi osio ja replikaatio. Käytä seuraavaa komentoa:
$ sudo -sisään linuxhint / valita / kafka / roskakori / kafka-topics.sh --luoda --bootstrap-palvelin paikallinen isäntä: 9092 --replikaatiokerroin 1 -- väliseinät 1 --aihe linuxhint1 
Huomaa, että aiheemme on luotu. Voimme nähdä edellisen viestin vahvistaaksemme sen.
Vaihtoehtoisesti voit luetella käytettävissä olevat aiheet käyttämällä -lista vaihtoehto seuraavassa komennossa. Sen pitäisi palauttaa aihe, jonka loimme:S
$ sudo -sisään linuxhint / valita / kafka / roskakori / kafka-topics.sh --lista --bootstrap-palvelin paikallinen isäntä: 9092 
Kun Kafka-aihe on luotu, voit aloittaa stream-tietojen kirjoittamisen Kafka-console-producer.sh ja tarkista, heijastuuko se sinuun kuluttaja.sh.
Avaa kuori ja siirry aiheeseen, jonka loimme tuottaja.sh:n avulla seuraavan kuvan mukaisesti:
$ sudo -sisään linuxhint / valita / kafka / roskakori / kafka-console-producer.sh --välityslista paikallinen isäntä: 9092 --aihe linuxhint1 
Avaa seuraavaksi toinen kuori ja siirry Kafka-aiheeseen käyttämällä kuluttaja.sh:ta.
Kun kaksi kuorta on auki, voit lähettää viestejä tuottajakonsolissa. Mitä tahansa kirjoitat, se näkyy kuluttajakonsolissa, mikä vahvistaa, että Apache Kafka on toiminnassa.
Johtopäätös
Tämän oppaan avulla sinulla on nyt kaikki vaiheet, joita voit noudattaa asentaaksesi Apache Kafkan Ubuntu 22.04:ään. Toivottavasti onnistuit seuraamaan jokaista vaihetta ja asentamaan Apache Kafkan ja luomaan aiheita yksinkertaisen kuluttaja- ja tuottajatuotannon suorittamiseksi. Voit toteuttaa saman suuressa tuotannossa.