So installieren Sie Apache Kafka in Ubuntu Top 10.Top 10

Apache Kafka ist eine von der Apache Software Foundation entwickelte Streaming -Plattform. Die Plattform ist Open-Source und verteilt und kann auf jeder Plattform installiert werden, sofern sie Java unterstützt. Außerdem ist Apache Kafka in Java und Scala geschrieben. Diese Anleitung gibt ein praktisches Tutorial zur Installation von Apache Kafka in Ubuntu 22.04.

Erste Schritte mit Apache Kafka

Vor der Installation des Apache Kafka müssen die Java installiert werden und ein Benutzerkonto mit Sudo -Berechtigungen. Darüber hinaus wird empfohlen, einen RAM von 2 GB und darüber zu haben, um den richtigen Kafka -Laufen zu erzielen.

In den folgenden Schritten werden Sie anhand der Installation der Apache Kafka angeleitet.

Java installieren

Java muss Kafka installieren. Überprüfen Sie, ob Ihr Ubuntu eine Java installiert hat, indem Sie die Version mit dem folgenden Befehl überprüfen:

$ java -Verssion

Wenn Java nicht installiert ist, verwenden Sie die folgenden Befehle, um die Java OpenJDK zu installieren.

$ sudo APT Update
$ sudo apt installieren Standard-JDK

Erstellen eines Benutzerkontos

Erstellen Sie mit bereits installiertem Java ein Nicht-Root-Benutzerkonto. Wir müssen ihm auch einige Sudo -Berechtigungen geben, indem wir den Benutzer mit dem folgenden Befehl zur sudo -Gruppe hinzufügen:

$ sudo adduser linuxHint
$ sudo adduser linuxHint sudo

Melden Sie sich beim neu erstellten Benutzerkonto an.

$ su -l linuxHint

Installieren von Kafka

Sie müssen die neueste Apache Kafka von der offiziellen Download -Seite herunterladen. Laden Sie seine Binärdateien mit dem herunter wget Befehl wie im Folgenden gezeigt:

$ wget https: // downloads.Apache.org/kafka/3.2.3/kafka_2.12-3.2.3.TGZ

Sobald die binäre Datei heruntergeladen wurde, extrahieren Sie sie mit der Teer Befehl und verschieben das extrahierte Verzeichnis auf die /opt/kafka.

Erstellen Sie als nächstes die Systemdskripte für die Zookeeper und das Kafka Dienstleistungen, die helfen, die Dienste zu starten und zu stoppen.

Verwenden Sie einen Editor der Wahl, um die Systemd -Skripte zu erstellen und den folgenden Inhalt einzufügen. Beginnen Sie mit dem Zookeeper:

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

Fügen Sie Folgendes ein:

[Einheit]
Beschreibung = Apache Zookeeper Server
Dokumentation = http: // zookeeper.Apache.Org
Erfordert = Netzwerk.Ziel-Remote-FS.Ziel
Nach = Netzwerk.Ziel-Remote-FS.Ziel
[Service]
Typ = einfach
Execstart =/opt/kafka/bin/zookeeper-server-start.sh/opt/kafka/config/zookeeper.Eigenschaften
ExecStop =/opt/kafka/bin/zookeeper-server-stop.Sch
Neu starten = on-abnormal
[Installieren]
Wantby by = multi-user.Ziel

Speicher die Datei. Erstellen Sie die Systemd -Datei für die KAFKA und fügen Sie den folgenden Inhalt ein:

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

Stellen Sie beim Einfügen sicher, dass Sie den richtigen Weg für die Java einstellen, die Sie in Ihrem System installiert haben.

[Einheit]
Beschreibung = Apache Kafka Server
Dokumentation = http: // kafka.Apache.Org/Dokumentation.html
Erfordert = Zookeeper.Service
[Service]
Typ = einfach
Umwelt = "java_home =/usr/lib/jvm/java-11-openjdk-amd64"
Execstart =/opt/kafka/bin/kafka-server-start.sh/opt/kafka/config/server.Eigenschaften
ExecStop =/opt/kafka/bin/kafka-server-stop.Sch
Neu starten = on-abnormal
[Installieren]
Wantby by = multi-user.Ziel

Wenden Sie nach Abschluss die Änderungen an, indem Sie den Systemd -Daemon neu laden:

$ sudo systemctl Daemon-Reload

Aktivieren Sie als Nächstes den Zookeeper -Dienst und starten Sie ihn mit den folgenden Befehlen:

$ sudo systemctl aktivieren Zookeeper
$ sudo systemctl starten zookepeR

Sie müssen auch das Gleiche für die Kafka tun:

$ sudo systemctl aktivieren kafka
$ sudo systemctl starten kafka

Sobald Sie die Dienste gestartet haben, können Sie ihren Status überprüfen, bevor wir ein Thema in Kafka erstellen.

Das Gute mit Kafka ist, dass es mehrere Skripte gibt, die Sie verwenden können.

Lassen Sie uns ein neues Thema namens erstellen LinuxHint1 Verwendung der Kafka-Topics.Sch Skript mit einer Partition und einer Replikation. Verwenden Sie den folgenden Befehl:

$ sudo -u linuxHint/opt/kafka/bin/kafka -topics.sh-create-Bootstrap-server localhost: 9092-Replikationsfaktor 1-Partitionen 1--topic linuxHint1

Beachten Sie, dass unser Thema erstellt wird. Wir können die vorherige Nachricht sehen, um dies zu überprüfen.

Alternativ können Sie die verfügbaren Themen mit dem auflisten -Liste Option im folgenden Befehl. Es sollte das von uns erstellte Thema zurückgeben: s

$ sudo -u linuxHint/opt/kafka/bin/kafka -topics.SH-List-Bootstrap-server localhost: 9092

Wenn das Kafka -Thema erstellt wird, können Sie die Streams -Daten auf dem schreiben Kafka-Console-Produzent.Sch und prüfen Sie, ob es sich in Ihrem widerspiegelt Verbraucher.Sch.

Öffnen Sie Ihre Shell und greifen Sie mit dem Produzenten auf das Thema zu, das wir erstellt haben.sh wie in Folgendes gezeigt:

$ sudo -u linuxHint/opt/kafka/bin/kafka-console-produzierter.SH-BROKER-LIST LOCALHOST: 9092-Topic LinuxHint1

Öffnen Sie als nächstes eine weitere Shell und greifen Sie mit dem Verbraucher auf das Thema Kafka zu.Sch.

$ sudo -u linuxHint/opt/kafka/bin/kafka-console-consumer.SH-Bootstrap-Server localhost: 9092--topic linuxHint1-From-Beinging

Wenn die beiden geöffneten Muscheln geöffnet sind, können Sie die Produzentenkonsole ausweisen. Was auch immer Sie tippen, spiegelt sich in der Verbraucherkonsole wider und bestätigt, dass unser Apache Kafka im Betrieb ist.

Abschluss

Mit dieser Anleitung haben Sie jetzt alle Schritte, die Sie ausführen können, um Apache Kafka in Ihrem Ubuntu 22 zu installieren.04. Hoffentlich haben Sie es gelungen, jedem Schritt zu folgen, Ihre Apache Kafka zu installieren und Themen zu erstellen, um eine einfache Produktion von Verbrauchern und Produzenten durchzuführen. Sie können dasselbe in großer Produktion implementieren.