Kom godt i gang med Apache Kafka
Før du installerer Apache Kafka, skal du have Java installeret og en brugerkonto med sudo-rettigheder. Desuden anbefales det at have en RAM på 2 GB og derover for korrekt drift af Kafka.
De følgende trin vil guide dig til, hvordan du installerer Apache Kafka.
Installation af Java
Java er påkrævet for at installere Kafka. Kontroller, om din Ubuntu har en Java installeret ved at kontrollere versionen ved hjælp af følgende kommando:
$ java --version
Hvis Java ikke er installeret, skal du bruge følgende kommandoer til at installere Java OpenJDK.
$ sudo passende installere default-jdk
Oprettelse af en brugerkonto
Med Java allerede installeret, opret en ikke-root brugerkonto. Vi skal også give det nogle sudo-privilegier ved at tilføje brugeren til sudo-gruppen ved hjælp af følgende kommando:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Log ind på den nyoprettede brugerkonto.
Installerer Kafka
Du skal downloade den seneste Apache Kafka fra den officielle downloadside. Download dens binære filer ved hjælp af 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 fil er downloadet, skal du udpakke den ved hjælp af tager kommandoen og flyt den udpakkede mappe til /opt/kafka.
Dernæst skal du oprette systemd scripts for Dyrepasser og Kafka tjenester, der hjælper med at starte og stoppe tjenesterne.
Brug en valgfri editor til at oprette de systemd scripts og indsætte følgende indhold. Start med dyrepasseren:
$ sudo nano / etc / systemd / system / zookeeper.serviceIndsæt følgende:
[ Enhed ]Beskrivelse =Apache Zookeeper-server
Dokumentation =http: // zookeeper.apache.org
Kræver =netværk.mål remote-fs.target
Efter =netværk.mål remote-fs.target
[ Service ]
Type = enkel
ExecStart = / opt / kafka / beholder / zookeeper-server-start.sh / opt / kafka / config / dyrepasser.ejendomme
ExecStop = / opt / kafka / beholder / zookeeper-server-stop.sh
Genstart = på-unormalt
[ Installere ]
Efterlyst Af =multi-user.target
Gem filen. Opret systemd-filen til Kafka og indsæt følgende indhold:
Når du indsætter, skal du sørge for at angive den rigtige sti til den Java, du har installeret på dit system.
[ Enhed ]Beskrivelse =Apache Kafka Server
Dokumentation =http: // kafka.apache.org / documentation.html
Kræver =zookeeper.service
[ Service ]
Type = enkel
Miljø = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / opt / kafka / beholder / kafka-server-start.sh / opt / kafka / config / server.egenskaber
ExecStop = / opt / kafka / beholder / kafka-server-stop.sh
Genstart = på-unormalt
[ Installere ]
Efterlyst Af =multi-user.target
Når det er gjort, skal du anvende ændringerne ved at genindlæse systemd-dæmonen:
Aktivér derefter Zookeeper-tjenesten og start den ved hjælp af følgende kommandoer:
$ sudo systemctl start zookeepe < stærk > r stærk >
Du skal også gøre det samme for Kafka:
$ sudo systemctl start kafka
Når du starter tjenesterne, kan du bekræfte deres status, før vi opretter et emne i Kafka.
Det gode ved Kafka er, at der er flere scripts, som du kan bruge.
Lad os oprette et nyt emne ved navn linuxhint1 bruger kafka-topics.sh script med én partition og en replikering. Brug følgende kommando:
$ sudo -i linuxhint / opt / kafka / beholder / kafka-topics.sh --skab --bootstrap-server lokal vært: 9092 --replikationsfaktor 1 --partitioner 1 --emne linuxhint1 
Bemærk, at vores emne er oprettet. Vi kan se den forrige besked for at bekræfte det.
Alternativt kan du liste de tilgængelige emner ved hjælp af -liste mulighed i følgende kommando. Det skulle returnere det emne, vi oprettede:S
$ sudo -i linuxhint / opt / kafka / beholder / kafka-topics.sh --liste --bootstrap-server lokal vært: 9092 
Når Kafka-emnet bliver oprettet, kan du begynde at skrive strømdataene på Kafka-console-producer.sh og tjek om det afspejler sig i din forbruger.sh.
Åbn din shell og få adgang til det emne, vi oprettede ved hjælp af producer.sh som vist i følgende:
$ sudo -i linuxhint / opt / kafka / beholder / kafka-console-producer.sh --mæglerliste lokal vært: 9092 --emne linuxhint1 
Åbn derefter en anden skal og få adgang til Kafka-emnet ved hjælp af consumer.sh.
Med de to skaller åbne, kan du sende beskeder på producentkonsollen. Uanset hvad du skriver, afspejles det i forbrugerkonsollen, der bekræfter, at vores Apache Kafka er oppe og køre.
Konklusion
Med denne guide har du nu alle de trin, du kan følge for at installere Apache Kafka i din Ubuntu 22.04. Forhåbentlig lykkedes det dig at følge hvert trin og installere din Apache Kafka og oprette emner til at køre en simpel forbruger- og producentproduktion. Du kan implementere det samme i stor produktion.