Komme i gang med Apache Kafka
Før du installerer Apache Kafka, må du ha Java installert og en brukerkonto med sudo-rettigheter. Dessuten anbefales det å ha en RAM på 2 GB og over for riktig drift av Kafka.
Følgende trinn vil veilede deg om hvordan du installerer Apache Kafka.
Installerer Java
Java kreves for å installere Kafka. Sjekk om din Ubuntu har en Java installert ved å sjekke versjonen ved å bruke følgende kommando:
$ java --versjon
Hvis Java ikke er installert, bruk følgende kommandoer for å installere Java OpenJDK.
$ sudo apt installere default-jdk
Opprette en brukerkonto
Med Java allerede installert, opprett en ikke-root brukerkonto. Vi må også gi den noen sudo-privilegier ved å legge brukeren til sudo-gruppen ved å bruke følgende kommando:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Logg inn på den nyopprettede brukerkontoen.
Installerer Kafka
Du må laste ned den nyeste Apache Kafka fra den offisielle nedlastingssiden. Last ned de binære filene ved hjelp av wget kommando som vist i følgende:
$ wget https: // downloads.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Når den binære filen er lastet ned, pakk den ut ved å bruke tar kommandoen og flytt den utpakkede katalogen til /opt/kafka.
Deretter oppretter du systemd skript for Dyrepasser og Kafka tjenester som hjelper til med å starte og stoppe tjenestene.
Bruk et redigeringsprogram for å lage systemskriptene og lim inn følgende innhold. Start med dyrepasseren:
$ sudo nano / etc / systemd / system / dyrepasser.tjenesteLim inn følgende:
[ Enhet ]Beskrivelse =Apache Zookeeper-server
Dokumentasjon =http: // zookeeper.apache.org
Krever =network.target ekstern-fs.target
Etter =network.target ekstern-fs.target
[ Service ]
Type = enkelt
ExecStart = / opt / kafka / bin / zookeeper-server-start.sh / opt / kafka / konfig / dyrepasser.eiendommer
ExecStop = / opt / kafka / bin / zookeeper-server-stop.sh
Omstart = på unormalt
[ Installere ]
Etterlyst Av =multi-user.target
Lagre filen. Lag systemd-filen for Kafka og lim inn følgende innhold:
Når du limer inn, sørg for at du angir riktig bane for Java-en du installerte i systemet.
[ Enhet ]Beskrivelse =Apache Kafka Server
Dokumentasjon =http: // kafka.apache.org / documentation.html
Krever =zookeeper.service
[ Service ]
Type = enkelt
Miljø = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / opt / kafka / bin / kafka-server-start.sh / opt / kafka / konfig / server.egenskaper
ExecStop = / opt / kafka / bin / kafka-server-stop.sh
Omstart = på unormalt
[ Installere ]
Etterlyst Av =multi-user.target
Når du er ferdig, bruk endringene ved å laste systemd-demonen på nytt:
Deretter aktiverer du Zookeeper-tjenesten og starter den ved å bruke følgende kommandoer:
$ sudo systemctl start zookeepe < sterk > r sterk >
Du må også gjøre det samme for Kafka:
$ sudo systemctl start kafka
Når du starter tjenestene, kan du bekrefte statusen deres før vi oppretter et emne i Kafka.
Det som er bra med Kafka er at det er flere skript du kan bruke.
La oss lage et nytt emne kalt linuxhint1 bruker kafka-topics.sh skript med én partisjon og en replikering. Bruk følgende kommando:
$ sudo -i linuxhint / opt / kafka / bin / kafka-topics.sh --skape --bootstrap-server lokal vert: 9092 --replikeringsfaktor 1 --partisjoner 1 --emne linuxhint1 
Merk at vårt emne er opprettet. Vi kan se den forrige meldingen for å bekrefte det.
Alternativt kan du liste de tilgjengelige emnene ved å bruke -liste alternativet i følgende kommando. Det skal returnere emnet som vi opprettet:S
$ sudo -i linuxhint / opt / kafka / bin / kafka-topics.sh --liste --bootstrap-server lokal vert: 9092 
Når Kafka-emnet blir opprettet, kan du begynne å skrive strømdataene på Kafka-console-producer.sh og sjekk om det gjenspeiles i din forbruker.sh.
Åpne skallet og få tilgang til emnet vi opprettet ved å bruke producer.sh som vist i følgende:
$ sudo -i linuxhint / opt / kafka / bin / kafka-console-producer.sh --meglerliste lokal vert: 9092 --emne linuxhint1 
Deretter åpner du et annet skall og får tilgang til Kafka-emnet ved å bruke consumer.sh.
Med de to skallene åpnet kan du sende meldinger på produsentkonsollen. Uansett hva du skriver gjenspeiles i forbrukerkonsollen som bekrefter at vår Apache Kafka er oppe og går.
Konklusjon
Med denne veiledningen har du nå alle trinnene du kan følge for å installere Apache Kafka i Ubuntu 22.04. Forhåpentligvis klarte du å følge hvert trinn og installere din Apache Kafka og lage emner for å drive en enkel forbruker- og produsentproduksjon. Du kan implementere det samme i stor produksjon.