## Schritt 1:Voraussetzungen
Stellen Sie vor der Installation von Apache Kafka sicher, dass Sie die folgenden Voraussetzungen erfüllen:
– Ubuntu 18.04-Server mit einem Nicht-Root-Benutzer mit „sudo“-Berechtigungen.
- Java Development Kit (JDK) 8 oder höher installiert.
- Zookeeper installiert und läuft. [Hier](/blog/how-to-install-zookeeper-on-ubuntu-1804) erfahren Sie, wie Sie ZooKeeper unter Ubuntu 18.04 installieren.
Schritt 2:Apache Kafka herunterladen
1. Besuchen Sie die offizielle Seite [Apache Kafka-Download](https://kafka.apache.org/download).
2. Klicken Sie im Abschnitt „Releases“ auf die neueste stabile Version (z. B. „2.8.0“).
3. Klicken Sie auf der Release-Seite auf den Link zum Herunterladen der Tarball-Datei (z. B. „kafka_2.12-2.8.0.tgz“).
4. Verwenden Sie „wget“, um die Tarball-Datei herunterzuladen:
„
wget https://www-us.apache.org/dist/kafka/2.8.0/kafka_2.12-2.8.0.tgz
„
Schritt 3:Extrahieren Sie den Tarball
Sobald der Download abgeschlossen ist, extrahieren Sie die Tarball-Datei in ein Verzeichnis Ihrer Wahl. In diesem Beispiel extrahieren wir es nach „/opt“:
„
sudo tar -xzvf kafka_2.12-2.8.0.tgz -C /opt
„
Dadurch wird ein Verzeichnis namens „/opt/kafka_2.12-2.8.0“ erstellt.
Schritt 4:Umgebungsvariablen festlegen
Um die Arbeit mit Kafka zu erleichtern, können Sie einige Umgebungsvariablen festlegen. Fügen Sie die folgenden Zeilen zu Ihrer Datei „/etc/profile“ hinzu:
„
exportieren Sie KAFKA_HOME=/opt/kafka_2.12-2.8.0
export PATH=$KAFKA_HOME/bin:$PATH
„
Speichern Sie die Datei und schließen Sie sie. Führen Sie dann den folgenden Befehl aus, um die Umgebungsvariablen zu aktualisieren:
„
Quelle /etc/profile
„
Schritt 5:Kafka-Benutzer erstellen
Um Kafka auszuführen, wird empfohlen, einen dedizierten Benutzer zu erstellen. Dies trägt dazu bei, Kafka-Prozesse von anderen Systemprozessen zu isolieren und erhöht die Sicherheit.
„
sudo adduser --system --group kafka
„
Schritt 6:Zookeeper konfigurieren
Kafka verlässt sich bei der Koordination auf Zookeeper. Bearbeiten Sie die Datei „config/zookeeper.properties“ im Kafka-Installationsverzeichnis:
„
sudo vi /opt/kafka_2.12-2.8.0/config/zookeeper.properties
„
Stellen Sie sicher, dass der Parameter „connect“ auf das Zookeeper-Ensemble verweist:
„
connect=localhost:2181
„
Speichern Sie die Datei und schließen Sie sie.
Schritt 7:Kafka konfigurieren
Als nächstes konfigurieren wir Kafka, indem wir die Datei „config/server.properties“ bearbeiten:
„
sudo vi /opt/kafka_2.12-2.8.0/config/server.properties
„
Hier sind die wichtigsten Einstellungen, die geändert werden müssen:
- Ersetzen Sie „broker.id“ durch eine eindeutige ID für diesen Broker (z. B. „0“, wenn es der erste Broker in Ihrem Cluster ist).
- Stellen Sie „zookeeper.connect“ so ein, dass es auf das Zookeeper-Ensemble verweist (z. B. „localhost:2181“).
– Erwägen Sie, den Parameter „log.dirs“ zu optimieren, um das Verzeichnis anzugeben, in dem Kafka seine Protokolle speichert.
- Überprüfen Sie andere Parameter wie „num.partitions“ und „default.replication.factor“ entsprechend Ihren Anforderungen.
Speichern Sie die Datei und schließen Sie sie.
Schritt 8:Themen erstellen
Themen sind die grundlegenden Einheiten der Datenspeicherung in Kafka. Um ein Thema zu erstellen, führen Sie den folgenden Befehl aus und ersetzen Sie „my-topic“ durch den gewünschten Themennamen:
„
/opt/kafka_2.12-2.8.0/bin/kafka-topics.sh --create --topic my-topic --partitions 1 --replication-factor 1 --zookeeper localhost:2181
„
Schritt 9:Kafka starten
Führen Sie den folgenden Befehl aus, um den Kafka-Broker zu starten:
„
/opt/kafka_2.12-2.8.0/bin/kafka-server-start.sh /opt/kafka_2.12-2.8.0/config/server.properties
„
Schritt 10:Kafka testen
Um zu testen, ob Kafka ordnungsgemäß funktioniert, können Sie die Tools „kafka-console-producer“ und „kafka-console-consumer“ verwenden.
Erstellen Sie eine Nachricht
Um eine Nachricht zu erstellen, führen Sie den folgenden Befehl aus und ersetzen Sie „my-topic“ durch Ihren Themennamen:
„
/opt/kafka_2.12-2.8.0/bin/kafka-console-producer.sh --topic my-topic --broker-list localhost:9092
„
Geben Sie in der Konsole eine Nachricht ein und drücken Sie die Eingabetaste.
Eine Nachricht konsumieren
Um die Nachricht zu verarbeiten, führen Sie den folgenden Befehl aus und ersetzen Sie „my-topic“ durch Ihren Themennamen:
„
/opt/kafka_2.12-2.8.0/bin/kafka-console-consumer.sh --topic my-topic --bootstrap-server localhost:9092 --from-beginning
„
In der Konsole sollten Sie die Nachricht sehen, die Sie zuvor erstellt haben.
Schritt 11:Firewall konfigurieren (optional)
Wenn Ihr Kafka-Server von außen nicht zugänglich ist, müssen Sie möglicherweise Ihre Firewall so konfigurieren, dass eingehende Verbindungen auf Port 9092 (oder einem beliebigen benutzerdefinierten Port, den Sie während der Konfiguration angegeben haben) zugelassen werden.
Schlussfolgerung
Sie haben Apache Kafka erfolgreich auf Ihrem Ubuntu 18.04-Server installiert und konfiguriert. Jetzt können Sie seine Fähigkeiten erkunden und mit der Entwicklung von Echtzeitanwendungen beginnen.
