Jak zainstalować Apache Kafka w Ubuntu Top 10.Top 10

Apache Kafka to platforma strumieniowa opracowana przez Apache Software Foundation. Platforma jest open source i rozpowszechniona i może być zainstalowana na dowolnej platformie, pod warunkiem, że obsługuje Java. Poza tym Apache Kafka jest napisany w Javie i Scali. Ten przewodnik zawiera praktyczny samouczek, jak zainstalować Apache Kafka w Ubuntu 22.04.

Pierwsze kroki z Apache Kafka

Przed zainstalowaniem Apache Kafka musisz zainstalować Java i konto użytkownika z uprawnieniami Sudo. Ponadto zaleca się posiadanie RAM o 2 GB i powyżej w celu właściwego biegania Kafki.

Poniższe kroki poprowadzą Cię, jak zainstalować Apache Kafka.

Instalowanie Java

Java jest zobowiązana do zainstalowania Kafki. Sprawdź, czy Twój Ubuntu ma zainstalowaną java, sprawdzając wersję za pomocą następującego polecenia:

$ java --version

Jeśli Java nie jest zainstalowana, użyj następujących poleceń, aby zainstalować Java OpenJDK.

Aktualizacja $ sudo apt
$ sudo apt Zainstaluj default-jdk

Tworzenie konta użytkownika

Po już zainstalowaniu Java utwórz konto użytkownika inne niż. Musimy również podać mu uprawnienia Sudo, dodając użytkownika do grupy sudo za pomocą następującego polecenia:

$ sudo adduser Linuxhint
$ sudo adduser Linuxhint sudo

Zaloguj się na nowo utworzone konto użytkownika.

$ su -l Linuxhint

Instalowanie Kafki

Musisz pobrać najnowszą Apache Kafka z oficjalnej strony pobierania. Pobierz jego pliki binarne za pomocą wget polecenie, jak pokazano w następujący sposób:

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

Po pobraniu pliku binarnego wyodrębnia go za pomocą smoła polecić i przenieść wyodrębniony katalog do /opt/kafka.

Następnie utwórz SKRIPTY SYSTEMD dla Zookeeper i Kafka Usługi, które pomagają w uruchomieniu i zatrzymaniu Usług.

Użyj wybranego edytora, aby utworzyć skrypty systemowe i wkleić następujące treści. Zacznij od Zookeepera:

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

Wklej następujące:

[Jednostka]
Opis = Apache Zookeeper Server
Dokumentacja = http: // Zookeeper.Apache.org
Wymaga = sieć.celowe zdalne fs.cel
Po = sieć.celowe zdalne fs.cel
[Praca]
Typ = prosty
ExecStart =/opt/kafka/bin/zookeeper-server-start.sh/opt/kafka/config/zookeeper.nieruchomości
Execstop =/opt/kafka/bin/zookeeper-server-stop.cii
Restart = nabółkowy
[Zainstalować]
Wantby = Multi-User.cel

Zapisz plik. Utwórz plik SystemD dla kafki i wklej następujące treści:

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

Podczas wklejania upewnij się, że ustawiłeś właściwą ścieżkę dla Java, którą zainstalowałeś w swoim systemie.

[Jednostka]
Opis = Apache Kafka Server
Dokumentacja = http: // kafka.Apache.org/dokumentacja.html
Wymaga = Zookeeper.praca
[Praca]
Typ = prosty
Środowisko = "java_home =/usr/lib/jvm/java-11-openjdk-amd64"
ExecStart =/opt/kafka/bin/kafka-server-start.sh/opt/kafka/config/serwer.nieruchomości
Execstop =/opt/kafka/bin/kafka-server-stop.cii
Restart = nabółkowy
[Zainstalować]
Wantby = Multi-User.cel

Po zakończeniu zastosuj zmiany, przeładowując demon SystemD:

$ sudo systemctl demon-powód

Następnie włącz usługę Zookeeper i uruchom ją przy użyciu następujących poleceń:

$ sudo systemCtl włącza Zookeeper
$ sudo systemctl start zookeepeR

Musisz również zrobić to samo dla Kafki:

$ sudo systemctl włącz Kafka
$ sudo systemctl start kafka

Po uruchomieniu usług możesz zweryfikować ich status, zanim utworzymy temat w Kafka.

Dobrą rzeczą w Kafce jest to, że istnieje wiele skryptów, których można użyć.

Utwórzmy nowy temat o nazwie Linuxhint1 używając Kafka-Topics.cii skrypt z jedną partycją i replikacją. Użyj następującego polecenia:

$ sudo -u linuxhint/opt/kafka/bin/kafka -topics.sh-Create-bootstrap-server localhost: 9092-Odreplikacja-fakt 1-partia 1-Topic Linuxhint1

Zauważ, że nasz temat jest tworzony. Widzimy poprzednią wiadomość, aby to zweryfikować.

Alternatywnie możesz wymienić dostępne tematy za pomocą -lista Opcja w następującym poleceniu. Powinien zwrócić temat, który stworzyliśmy: S

$ sudo -u linuxhint/opt/kafka/bin/kafka -topics.sh--list-bootstrap-server localhost: 9092

Po utworzeniu tematu Kafka możesz zacząć pisać dane strumieniowe na Kafka-Console-producer.cii i sprawdź, czy odzwierciedla to w twoim konsument.cii.

Otwórz swoją powłokę i uzyskaj dostęp do tematu, który stworzyliśmy za pomocą producenta.SH, jak pokazano następująco:

$ sudo -u Linuxhint/opt/kafka/bin/kafka-console-producer.SH-Broker-List LocalHost: 9092-Topic Linuxhint1

Następnie otwórz kolejną powłokę i uzyskaj dostęp do tematu Kafka za pomocą konsumenta.cii.

$ sudo -u Linuxhint/opt/kafka/bin/kafka-konsol-konsol-konsolowy.sh-bootstrap-server localhost: 9092-Topic Linuxhint1--From-beginning

Po otwarciu dwóch skorup możesz wysłać wiadomość na konsoli producenta. Cokolwiek wpiszesz, znajduje odzwierciedlenie w konsoli konsumenckiej, potwierdzając, że nasz Apache Kafka działa i uruchamia.

Wniosek

W tym przewodniku masz teraz wszystkie kroki, które możesz wykonać, aby zainstalować Apache Kafka w Ubuntu 22.04. Mamy nadzieję, że udało ci się zastosować każdy krok i zainstalować Apache Kafka i utworzyć tematy, aby uruchomić prostą produkcję konsumentów i producentów. Możesz wdrożyć to samo w dużej produkcji.