Hvordan installere Apache Kafka i Ubuntu Topp 10.Topp 10

Apache Kafka er en streamingplattform utviklet av Apache Software Foundation. Plattformen er åpen kildekode og distribuert, og kan installeres på hvilken som helst plattform forutsatt at den støtter Java. Dessuten er Apache Kafka skrevet i Java og Scala. Denne guiden gir en praktisk opplæring om hvordan du installerer Apache Kafka i Ubuntu 22.04.

Komme i gang med Apache Kafka

Før du installerer Apache Kafka, må du ha Java installert og en brukerkonto med sudo -privilegier. Dessuten anbefales det å ha en RAM på 2 GB og over for riktig drift av Kafka.

Følgende trinn vil veilede deg for hvordan du installerer Apache Kafka.

Installere Java

Java er pålagt å installere kafka. Sjekk om 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 oppdatering
$ sudo apt install standard-jdk

Opprette en brukerkonto

Med Java som allerede er installert, oppretter du en ikke-root brukerkonto. Vi må også gi det noen sudo -privilegier ved å legge brukeren til Sudo -gruppen ved å bruke følgende kommando:

$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo

Logg deg på den nyopprettede brukerkontoen.

$ su -l linuxhint

Installere Kafka

Du må laste ned den siste Apache Kafka fra den offisielle nedlastingssiden. Last ned binære filer ved hjelp av WGET Kommando som vist i følgende:

$ wget https: // nedlastinger.Apache.org/kafka/3.2.3/Kafka_2.12-3.2.3.tgz

Når den binære filen er lastet ned, trekker den ut ved å bruke tjære kommando og flytte den ekstraherte katalogen til /opt/kafka.

Neste, lage SystemD -skript for Dyrepasser og Kafka tjenester som hjelper til med å starte og stoppe tjenestene.

Bruk en valgt redaktør for å lage SystemD -skriptene og lime inn følgende innhold. Begynn med dyrepassen:

$ sudo nano/etc/systemd/system/zookeeper.service

Lim inn følgende:

[Enhet]
Beskrivelse = Apache Zookeeper Server
Dokumentasjon = http: // zookeeper.Apache.org
Krever = nettverk.Mål fjern-FS.mål
Etter = nettverk.Mål fjern-FS.mål
[Service]
Type = enkel
ExecStart =/opt/kafka/bin/zookeeper-server-start.sh/opt/kafka/config/zookeeper.egenskaper
ExecStop =/opt/kafka/bin/zookeeper-server-stop.sh
Restart = On-Abnormal
[Installere]
WantedBy = Multi-User.mål

Lagre filen. Lag SystemD -filen for Kafka og lim inn følgende innhold:

$ sudo nano/etc/systemd/system/kafka.service

Når du limer inn, må du sørge for at du setter riktig vei for Java som du installerte i systemet ditt.

[Enhet]
Beskrivelse = Apache Kafka Server
Dokumentasjon = http: // kafka.Apache.org/dokumentasjon.html
Krever = Zookeeper.service
[Service]
Type = enkel
Miljø = "Java_Home =/usr/lib/jvm/java-11-openjdk-amd64"
ExecStart =/opt/kafka/bin/kafka-server-start.sh/opt/kafka/config/server.egenskaper
ExecStop =/opt/kafka/bin/kafka-server-stop.sh
Restart = On-Abnormal
[Installere]
WantedBy = Multi-User.mål

Når du er ferdig, bruker du endringene ved å laste inn Systemd Daemon:

$ sudo SystemCTL Daemon-Reload

Deretter aktiverer du ZooKeeper -tjenesten og start den med følgende kommandoer:

$ sudo SystemCTL Enable ZooKeeper
$ sudo systemctl start zookeeper

Du må også gjøre det samme for Kafka:

$ sudo systemctl aktiver kafka
$ sudo systemctl start kafka

Når du har startet tjenestene, kan du bekrefte deres status før vi oppretter et emne i Kafka.

Det gode med Kafka er at det er flere skript som du kan bruke.

La oss lage et nytt tema som heter Linuxhint1 bruker Kafka-emner.sh manus med en partisjon og en replikasjon. Bruk følgende kommando:

$ sudo -u linuxhint/opt/kafka/bin/kafka -emner.SH-Create-Bootstrap-Server LocalHost: 9092-Replication-Factor 1-Partitions 1-Topic Linuxhint1

Merk at emnet vårt er opprettet. Vi kan se den forrige meldingen for å bekrefte det.

Alternativt kan du liste opp de tilgjengelige emnene ved å bruke -liste Alternativ i følgende kommando. Det skulle returnere emnet vi opprettet: S

$ sudo -u linuxhint/opt/kafka/bin/kafka -emner.sh--list-bootstrap-server localhost: 9092

Når Kafka -emnet opprettes, kan du begynne å skrive strømmerdataene på Kafka-Console-produsent.sh og sjekk om det gjenspeiler i din forbruker.sh.

Åpne skallet ditt og få tilgang til emnet som vi opprettet ved hjelp av produsenten.SH som vist i følgende:

$ sudo -u linuxhint/opt/kafka/bin/kafka-console-produsent.SH-BROKER-LIST LOCALHOST: 9092-Topic Linuxhint1

Deretter åpner du et annet skall og får tilgang til Kafka -emnet ved hjelp av forbrukeren.sh.

$ sudo -u linuxhint/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost: 9092-tema Linuxhint1-fra-Beginning

Med de to skjellene åpnet, kan du sende beskjed på produsentkonsollen. Uansett hva du skriver gjenspeiles i forbrukerkonsollen som bekrefter at Apache Kafka vår er i gang.

Konklusjon

Med denne guiden 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 Apache Kafka og lage emner for å drive en enkel forbruker- og produsentproduksjon. Du kan implementere det samme i stor produksjon.