Zainstaluj Apache Kafka na Ubuntu

Apache Kafka to usługa brokera, taka jak ActiveMQ i Rabbitmq. Możesz dowiedzieć się więcej o Apache Kafka na https: // kafka.Apache.ORG W tym artykule pokażę, jak zainstalować Apache Kafka i sprawdzić, czy działa na Ubuntu 17.10 Artful Aardvark. Zacznijmy.

Instalowanie Apache Kafka

Najpierw zaktualizuj pamięć podręczną repozytorium pakietów serwera Ubuntu za pomocą następującego polecenia:

Aktualizacja $ sudo apt-get

Pamięć podręczna repozytorium pakietów powinna zostać zaktualizowana.

Apache Kafka zależy od Java. Możesz zainstalować OpenJDK 8 na Ubuntu 17.10 z oficjalnego repozytorium pakietów.

Uruchom następujące polecenie, aby zainstalować OpenJDK 8 na Ubuntu 17.10:

$ sudo apt-get instaluj openjdk-8-jdk

Teraz naciśnij „y”, a następnie naciśnij, aby kontynuować.

Należy zainstalować openjdk 8.

Teraz musisz zainstalować Zookeeper. Jest dostępny w oficjalnym repozytorium pakietów Ubuntu.

Żeby zainstalować Zookeeper, Uruchom następujące polecenie:

$ sudo apt-get instaluj Zookeeperd

Teraz naciśnij „y”, a następnie naciśnij, aby kontynuować.

Zookeeper należy zainstalować.

Możesz uruchomić następujące polecenie, aby sprawdzić, czy Zookeeper biegnie:

$ sudo systemCtl status Zookeeper

Jak widać na zrzucie ekranu poniżej, Zookeeper biegnie.

Jeśli z jakiegoś powodu nie działa na twoim komputerze, możesz zacząć Zookeeper Z następującym poleceniem:

$ sudo systemctl start zookeeper

Powinieneś dodać Zookeeper do startupu systemowego. Więc zacznie się automatycznie od rozruchu.

Uruchom następujące polecenie, aby dodać Zookeeper do uruchamiania systemu:

$ sudo systemCtl włącza Zookeeper

Zookeeper należy dodać do uruchamiania systemu, jak widać na zrzucie ekranu poniżej.

potrzebuję Netstat polecenie dostarczone przez narzędzia netto pakiet.

Teraz zainstaluj narzędzia netto Pakiet z następującym poleceniem:

$ sudo apt-get instalowanie narzędzi netto

narzędzia netto Pakiet powinien być zainstalowany.

Teraz możesz uruchomić następujące polecenie, aby sprawdzić, czy Zookeeper działa na porcie 2181.

$ sudo netstat -tulpen | GREP 2181

Jak widać, działa na porcie 2181.

Teraz uruchom następujące polecenie, aby przejść do katalogu ~/ pobierania/ w katalogu domowym użytkowników:

$ cd ~/pobieranie

Teraz musisz pobrać Apache Kafka. W momencie pisania najnowszą wersją Apache Kafka to v1.0.0.

Uruchom następujące polecenie, aby pobrać Apache Kafka 1.0.0 z wget:

$ wget http: // www-eu.Apache.org/dist/kafka/1.0.0/kafka_2.12-1.0.0.TGZ

Należy pobrać archiwum skompresowane Apache Kafka.

Jak widać z wyjścia polecenia LS, nazwa pliku archiwum Apache Kafka jest kafka_2.12-1.0.0.TGZ

Teraz utwórz katalog Kafka/ w /optować Katalog z następującym poleceniem:

$ sudo mkdir /opt /kafka

Katalog /opt/kafka należy utworzyć. W tym miejscu wyodrębnię archiwum.

Teraz wyodrębnij archiwum Apache Kafka w /opt/kafka Katalog z następującym poleceniem:

$ sudo tar xvzf kafka_2.12-1.0.0.TGZ -C /Opt /Kafka

Archiwum należy wyodrębnić.

Możesz uruchomić następujące polecenie, aby sprawdzić nazwę katalogu:

$ ls /opt /kafka

Zwróć uwagę na nazwę katalogu.

Teraz otwarte /itp./Profil Z następującym poleceniem:

$ sudo nano /itp. /profil

Dodaj następujące wiersze na końcu pliku i zapisz je.

Teraz otwórz ~/.Bashrc Plik z następującym poleceniem:

$ sudo nano ~/.Bashrc

Dodaj oznaczoną linię na koniec pliku jako zapisz.

Teraz uruchom ponownie komputer za pomocą następującego polecenia:

$ sudo restart

Po uruchomieniu komputera możesz sprawdzić, czy zmienne środowiskowe są dodawane w następujący sposób:

$ echo $ kafka_home

$ echo $ ścieżka

Teraz, aby ułatwić nam życie, zrób symboliczny link do Kafki serwer.nieruchomości Plik w następujący sposób:

$ sudo ln -s $ kafka_home/config/serwer.właściwości /etc /kafka.nieruchomości

Jak widać na zrzucie ekranu poniżej, tworzony jest link symboliczny.

Teraz możesz uruchomić serwer Apache Kafka z następującym poleceniem:

$ sudo kafka-server-start.sh /etc /kafka.nieruchomości

Serwer Apache Kafka powinien zostać uruchomiony.

Testowanie Apache Kafka Server

Możesz utworzyć temat testowy Testowanie na serwerze Apache Kafka z następującym poleceniem:

$ sudo kafka-topics.SH-Create --zookeeper LocalHost: 2181-Odreplikacja Factor 1
--partycje 1 -Testy topowe

A Testowanie Temat należy utworzyć, jak pokazano na zrzucie ekranu poniżej.

Teraz uruchom następujące polecenie, aby użyć interfejsu API producenta Kafka, aby wysłać wiadomość do Testowanie temat:

$ sudo kafka-console-producer.SH-Broker-List LocalHost: 9092-Testowanie topowe

Po naciśnięciu powinieneś zobaczyć nowy znak strzałki (>), jak pokazano na zrzucie ekranu poniżej.

Po prostu wpisz coś i naciśnij, aby uruchomić nową linię. Wpisałem 3 linie tekstów.

Teraz możesz użyć interfejsu API Kafka Consumer do pobrania wiadomości/linii z Testowanie Temat z następującym poleceniem:

$ Sudo Kafka-Console-Consumer.sh -zookeeper LocalHost: 2181 --
TESTOWANIE TEMATY-od-beginning

Powinieneś być w stanie zobaczyć wiadomości lub linie, które napisałeś za pomocą interfejsu API producenta, jak zaznaczono na zrzucie ekranu poniżej.

Jeśli napiszesz nową wiadomość za pomocą interfejsu API producenta, powinien być również wyświetlany natychmiast po stronie konsumenta, jak pokazano na zrzucie ekranu poniżej.

W ten sposób instalujesz Apache Kafka i weryfikujesz jego działanie na Ubuntu 17.10 Artful Aardvark. Dziękujemy za przeczytanie tego artykułu.