Komma igång med Apache Kafka
Innan du installerar Apache Kafka måste du ha Java installerat och ett användarkonto med sudo-privilegier. Dessutom rekommenderas det att ha ett RAM-minne på 2 GB eller mer för att Kafka ska fungera korrekt.
Följande steg guidar dig om hur du installerar Apache Kafka.
Installerar Java
Java krävs för att installera Kafka. Kontrollera om din Ubuntu har en Java installerad genom att kontrollera versionen med följande kommando:
$ java --version
Om Java inte är installerat, använd följande kommandon för att installera Java OpenJDK.
$ sudo benägen Installera default-jdk
Skapa ett användarkonto
Med Java redan installerat, skapa ett icke-rootanvändarkonto. Vi måste också ge det några sudo-privilegier genom att lägga till användaren i sudo-gruppen med följande kommando:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Logga in på det nyskapade användarkontot.
Installerar Kafka
Du måste ladda ner den senaste Apache Kafka från den officiella nedladdningssidan. Ladda ner dess binära filer med hjälp av wget kommando som visas i följande:
$ wget https: // downloads.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
När den binära filen har laddats ner, extrahera den med hjälp av tar kommandot och flytta den extraherade katalogen till /opt/kafka.
Skapa sedan systemd skript för Djurskötare och den Kafka tjänster som hjälper till att starta och stoppa tjänsterna.
Använd en valfri redigerare för att skapa systemskripten och klistra in följande innehåll. Börja med djurskötaren:
$ sudo nano / etc / systemd / systemet / zookeeper.serviceKlistra in följande:
[ Enhet ]Beskrivning =Apache Zookeeper-server
Dokumentation =http: // zookeeper.apache.org
Kräver =network.target remote-fs.target
Efter =network.target remote-fs.target
[ Service ]
Typ = enkel
ExecStart = / välja / kafka / bin / zookeeper-server-start.sh / välja / kafka / config / djurskötare.fastigheter
ExecStop = / välja / kafka / bin / zookeeper-server-stop.sh
Omstart = på onormalt
[ Installera ]
EfterlystAv =multi-user.target
Spara filen. Skapa systemd-filen för Kafka och klistra in följande innehåll:
När du klistrar in, se till att du ställer in rätt sökväg för Java som du installerade i ditt system.
[ Enhet ]Beskrivning =Apache Kafka Server
Dokumentation =http: // kafka.apache.org / documentation.html
Kräver =zookeeper.service
[ Service ]
Typ = enkel
Miljö = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / välja / kafka / bin / kafka-server-start.sh / välja / kafka / config / server.egenskaper
ExecStop = / välja / kafka / bin / kafka-server-stop.sh
Omstart = på onormalt
[ Installera ]
EfterlystAv =multi-user.target
När du är klar, tillämpa ändringarna genom att ladda om systemd-demonen:
Aktivera sedan Zookeeper-tjänsten och starta den med följande kommandon:
$ sudo systemctl starta zookeepe < stark > r stark >
Du måste också göra samma sak för Kafka:
$ sudo systemctl starta kafka
När du väl har startat tjänsterna kan du verifiera deras status innan vi skapar ett ämne i Kafka.
Det som är bra med Kafka är att det finns flera skript som du kan använda.
Låt oss skapa ett nytt ämne som heter linuxhint1 använda kafka-topics.sh skript med en partition och en replikering. Använd följande kommando:
$ sudo -i linuxhint / välja / kafka / bin / kafka-topics.sh --skapa --bootstrap-server lokal värd: 9092 --replikeringsfaktor 1 --partitioner 1 --ämne linuxhint1 
Observera att vårt ämne är skapat. Vi kan se det föregående meddelandet för att verifiera det.
Alternativt kan du lista de tillgängliga ämnena med hjälp av -lista alternativet i följande kommando. Det bör returnera ämnet som vi skapade:S
$ sudo -i linuxhint / välja / kafka / bin / kafka-topics.sh --lista --bootstrap-server lokal värd: 9092 
När Kafka-ämnet skapas kan du börja skriva strömningsdata på Kafka-console-producer.sh och kontrollera om det återspeglas i din konsument.sh.
Öppna ditt skal och få tillgång till ämnet som vi skapade med hjälp av producer.sh som visas i följande:
$ sudo -i linuxhint / välja / kafka / bin / kafka-console-producer.sh --mäklarlista lokal värd: 9092 --ämne linuxhint1 
Öppna sedan ett annat skal och gå till Kafka-ämnet med hjälp av consumer.sh.
Med de två skalen öppna kan du skicka meddelanden på producentkonsolen. Vad du än skriver återspeglas i konsumentkonsolen som bekräftar att vår Apache Kafka är igång.
Slutsats
Med den här guiden har du nu alla steg som du kan följa för att installera Apache Kafka i din Ubuntu 22.04. Förhoppningsvis lyckades du följa varje steg och installera din Apache Kafka och skapa ämnen för att driva en enkel konsument- och producentproduktion. Du kan implementera samma sak i stor produktion.