Pierwsze kroki z Apache Kafka
Przed zainstalowaniem Apache Kafka musisz mieć zainstalowaną Javę i konto użytkownika z uprawnieniami sudo. Co więcej, do prawidłowego działania Kafki zaleca się posiadanie pamięci RAM o pojemności 2 GB i wyższej.
Poniższe kroki pomogą Ci zainstalować Apache Kafka.
Instalowanie Javy
Do zainstalowania Kafki wymagana jest Java. Sprawdź, czy Twój Ubuntu ma zainstalowaną Javę, sprawdzając wersję za pomocą następującego polecenia:
$ Jawa --wersja
Jeśli Java nie jest zainstalowana, użyj następujących poleceń, aby zainstalować Java OpenJDK.
$ sudo trafny zainstalować default-jdk
Tworzenie konta użytkownika
Mając już zainstalowaną Javę, utwórz konto użytkownika innego niż root. Musimy również nadać mu pewne uprawnienia sudo, dodając użytkownika do grupy sudo za pomocą następującego polecenia:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Zaloguj się do nowo utworzonego konta użytkownika.
Instalowanie Kafki
Musisz pobrać najnowszą wersję Apache Kafka z oficjalnej strony pobierania. Pobierz jego pliki binarne za pomocą wget polecenie, jak pokazano poniżej:
$ wget https: // downloads.apache.org / Kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Po pobraniu pliku binarnego wyodrębnij go za pomocą trwa polecenie i przenieś wyodrębniony katalog do /opt/kafka.
Następnie utwórz skrypty systemowe dla dozorca zoo i Kafka usługi, które pomagają w uruchamianiu i zatrzymywaniu usług.
Użyj wybranego edytora, aby utworzyć skrypty systemd i wkleić poniższą zawartość. Zacznij od Opiekuna Zoo:
$ sudo nano / itp / systemd / system / zookeeper.serwisWklej następujące:
[ Jednostka ]Opis = Serwer Apache Zookeeper
Dokumentacja =http: // zookeeper.apache.org
Wymaga =sieć.cel zdalny-fs.cel
Później =sieć.cel zdalny-fs.cel
[ Usługa ]
Rodzaj =proste
Rozpocznij Ex = / optować / Kafka / kosz / zookeeper-server-start.sh / optować / Kafka / konfiguracja / zookeeper.properties
ExecStop = / optować / Kafka / kosz / zookeeper-server-stop.sh
Uruchom ponownie =wł.nienormalnie
[ zainstalować ]
Poszukiwany przez =wielu użytkowników.cel
Zapisz plik. Utwórz plik systemd dla Kafki i wklej następującą zawartość:
Podczas wklejania upewnij się, że ustawiłeś właściwą ścieżkę dla Javy, którą zainstalowałeś w swoim systemie.
[ Jednostka ]Opis =Serwer Apache Kafka
Dokumentacja =http: // kafka.apache.org / dokumentacja.html
Wymaga =opiekun.zoo.opiekuna
[ Usługa ]
Rodzaj =proste
Środowisko = „JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64”
Rozpocznij Ex = / optować / Kafka / kosz / kafka-server-start.sh / optować / Kafka / konfiguracja / server.properties
ExecStop = / optować / Kafka / kosz / kafka-server-stop.sh
Uruchom ponownie =wł.nienormalnie
[ zainstalować ]
Poszukiwany przez =wielu użytkowników.cel
Po zakończeniu zastosuj zmiany, ponownie ładując demona systemd:
Następnie włącz usługę Zookeeper i uruchom ją za pomocą następujących poleceń:
$ sudo systemctl uruchom zookeepe < silny > r silny >
To samo musisz zrobić dla Kafki:
$ sudo systemctl start kafka
Po uruchomieniu usług możesz zweryfikować ich status, zanim utworzymy temat w Kafce.
Dobrą rzeczą w Kafce jest to, że istnieje wiele skryptów, z których możesz korzystać.
Stwórzmy nowy temat o nazwie linuxhint1 używając kafka-topics.sh skrypt z jedną partycją i replikacją. Użyj następującego polecenia:
$ sudo -w linuxhint / optować / Kafka / kosz / kafka-topics.sh --Stwórz --bootstrap-server Lokalny Gospodarz: 9092 --współczynnik-replikacji 1 --partycje 1 --temat linuxhint1 
Zauważ, że nasz temat został utworzony. Widzimy poprzednią wiadomość, aby to zweryfikować.
Alternatywnie możesz wyświetlić listę dostępnych tematów za pomocą -lista w następującym poleceniu. Powinien zwrócić temat, który stworzyliśmy:S
$ sudo -w linuxhint / optować / Kafka / kosz / kafka-topics.sh --lista --bootstrap-server Lokalny Gospodarz: 9092 
Po utworzeniu tematu Kafki możesz zacząć pisać dane strumieni na Kafka-konsola-producent.sh i sprawdź, czy odzwierciedla się to w Twoim konsument.sz.
Otwórz powłokę i przejdź do tematu, który utworzyliśmy za pomocą pliku produce.sh, jak pokazano poniżej:
$ sudo -w linuxhint / optować / Kafka / kosz / kafka-konsola-producent.sh --lista-brokerów Lokalny Gospodarz: 9092 --temat linuxhint1 
Następnie otwórz kolejną powłokę i uzyskaj dostęp do tematu Kafki za pomocą pliku consumer.sh.
Po otwarciu obu powłok możesz wysłać wiadomość na konsoli producenta. Cokolwiek wpiszesz, zostanie odzwierciedlone w konsoli konsumenckiej, potwierdzając, że nasz Apache Kafka jest już uruchomiony.
Wniosek
Dzięki temu przewodnikowi masz teraz wszystkie kroki, które możesz wykonać, aby zainstalować Apache Kafka na swoim Ubuntu 22.04. Mamy nadzieję, że udało Ci się prześledzić każdy krok i zainstalować Apache Kafka oraz stworzyć tematy do uruchomienia prostej produkcji konsumenckiej i producenckiej. To samo możesz wdrożyć w dużej produkcji.