Installieren Sie Apache Kafka auf Ubuntu
Installieren von Apache Kafka
Aktualisieren Sie zuerst den Paket -Repository -Cache Ihres Ubuntu -Servers mit dem folgenden Befehl:
$ sudo apt-Get-Update
Der Paket -Repository -Cache sollte aktualisiert werden.
Apache Kafka hängt von Java ab. Sie können OpenJDK 8 auf Ubuntu 17 installieren.10 aus dem offiziellen Paketrepository.
Führen Sie den folgenden Befehl aus, um OpenJDK 8 auf Ubuntu 17 zu installieren.10:
$ sudo apt-Get Installieren Sie OpenJDK-8-JDK
Drücken Sie nun "y" und drücken Sie dann weiter, um fortzufahren.
OpenJDK 8 sollte installiert werden.
Jetzt müssen Sie installieren Zookeeper. Es ist im offiziellen Paket -Repository von Ubuntu erhältlich.
Installieren Zookeeper, Führen Sie den folgenden Befehl aus:
$ sudo apt-get zookeeperd installieren
Drücken Sie nun "y" und drücken Sie dann weiter, um fortzufahren.
Zookeeper sollte installiert werden.
Sie können den folgenden Befehl ausführen, um zu überprüfen, ob Zookeeper läuft:
$ sudo systemctl Status Zookeeper
Wie Sie aus dem Screenshot unten sehen können, Zookeeper läuft.
Wenn es aus irgendeinem Grund nicht auf Ihrem Computer ausgeführt wird, können Sie beginnen Zookeeper mit dem folgenden Befehl:
$ sudo systemctl starten zookeeper
Sie sollten hinzufügen Zookeeper zum System -Startup. Es startet also automatisch mit dem Start.
Führen Sie den folgenden Befehl aus, um hinzuzufügen Zookeeper zum Systemstart:
$ sudo systemctl aktivieren Zookeeper
Zookeeper sollte dem Systemstart hinzugefügt werden, wie Sie im folgenden Screenshot sehen können.
Ich brauche Netstat Befehl, der von der bereitgestellt wird Net-Tools Paket.
Jetzt installieren Net-Tools Paket mit dem folgenden Befehl:
$ sudo apt-Get Installieren Sie Net-Tools
Net-Tools Paket sollte installiert werden.
Jetzt können Sie den folgenden Befehl ausführen, um zu überprüfen, ob Zookeeper auf Port 2181 ausgeführt wird.
$ sudo netstat -tulpen | Grep 2181
Wie Sie sehen können, läuft es auf Port 2181.
Führen Sie nun den folgenden Befehl aus, um zum Verzeichnis ~/ Downloads/ Verzeichnis in Ihrem Benutzer zu navigieren:
$ cd ~/downloads
Jetzt müssen Sie Apache Kafka herunterladen. Zum Zeitpunkt des Schreibens ist die neueste Version von Apache Kafka V1.0.0.
Führen Sie den folgenden Befehl aus, um Apache Kafka 1 herunterzuladen.0.0 mit wget:
$ wget http: // www-euu.Apache.org/dist/kafka/1.0.0/kafka_2.12-1.0.0.TGZ
Apache Kafka Compressed Archiv sollte heruntergeladen werden.
Wie Sie aus der Ausgabe des LS -Befehls sehen können, ist der Dateiname des Apache Kafka -Archivs Kafka_2.12-1.0.0.TGZ
Erstellen Sie nun ein Verzeichnis Kafka/ im /opt Verzeichnis mit dem folgenden Befehl:
$ sudo mkdir /opt /kafka
Ein Verzeichnis /opt/kafka sollte erstellt werden. Hier werde ich das Archiv extrahieren.
Extrahieren Sie nun das Apache Kafka -Archiv in der /opt/kafka Verzeichnis mit dem folgenden Befehl:
$ sudo tar xvzf kafka_2.12-1.0.0.TGZ -c /opt /kafka
Das Archiv sollte extrahiert werden.
Sie können den folgenden Befehl ausführen, um den Verzeichnisnamen zu überprüfen:
$ ls /opt /kafka
Beachten Sie diesen Verzeichnisnamen.
Jetzt offen /etc/Profil mit dem folgenden Befehl:
$ sudo nano /etc /Profil
Fügen Sie die folgenden Zeilen zum Ende der Datei hinzu und speichern Sie sie.
Jetzt öffne die ~/.bashrc Datei mit dem folgenden Befehl:
$ sudo nano ~/.bashrc
Fügen Sie die markierte Zeile zum Ende der Datei als Speichern hinzu.
Starten Sie nun Ihren Computer mit dem folgenden Befehl neu:
$ sudo Neustart
Sobald Ihr Computer startet, können Sie überprüfen, ob die Umgebungsvariablen wie folgt hinzugefügt werden:
$ echo $ kafka_home
$ echo $ path
Machen Sie jetzt, um unser Leben einfacher zu machen, eine symbolische Verbindung von Kafka Server.Eigenschaften Datei wie folgt:
$ sudo ln -S $ kafka_home/config/server.Eigenschaften /etc /kafka.Eigenschaften
Wie Sie aus dem Screenshot unten sehen können, wird der symbolische Link erstellt.
Jetzt können Sie den Apache Kafka Server mit dem folgenden Befehl starten:
$ sudo kafka-server-start.sh /etc /kafka.Eigenschaften
Apache Kafka Server sollte gestartet werden.
Testen Sie Apache Kafka Server
Sie können ein Testthema erstellen testen Auf Apache Kafka Server mit dem folgenden Befehl:
$ sudo kafka-topics.sh-create-Zookeeper localhost: 2181-Replikationsfaktor 1
--Partitionen 1 -topische Tests
A testen Das Thema sollte wie im folgenden Screenshot erstellt werden.
Führen Sie nun den folgenden Befehl aus, um die Kafka -Produzent -API zu verwenden, um eine Nachricht an die zu senden testen Thema:
$ sudo Kafka-Console-Produzent.SH-BROKER-LIST LOCALHOST: 9092--Topische Tests
Sobald Sie drücken.
Geben Sie einfach etwas ein und drücken Sie, um eine neue Linie zu starten. Ich tippte 3 Zeilen von Texten ein.
Jetzt können Sie die Kafka Consumer -API verwenden, um die Nachrichten/Zeilen von der abzurufen testen Thema mit dem folgenden Befehl:
$ sudo kafka-console-consumer.SH -Zookeeper Localhost: 2181 --
Thementests-From-Beinging
Sie sollten in der Lage sein, die Nachrichten oder Zeilen zu sehen, die Sie mit der Produzenten -API geschrieben haben, wie im Screenshot unten markiert.
Wenn Sie eine neue Nachricht mit der Produzenten -API schreiben, sollte sie auch sofort auf der Verbraucherseite angezeigt werden, wie im Screenshot unten gezeigt.
So installieren Sie Apache Kafka und überprüfen, ob es an Ubuntu 17 funktioniert.10 kunstvolles Aardvark. Danke, dass du diesen Artikel gelesen hast.