Centos

Jak zainstalować Apache Kafka w Centos/Rhel 7

Jak zainstalować Apache Kafka w Centos/Rhel 7

Apache Kafka to potężny silnik przesyłania wiadomości, który jest szeroko stosowany Bigdata projekty i Analityka danych koło życia. Jest to platforma typu open source do budowania rurociągów strumieniowych danych w czasie rzeczywistym. Jest to rozproszona platforma publikacji Subskrypcji o niezawodności, skalowalności i trwałości.

Możemy mieć Kafka jako samodzielny lub jako klaster. Kafka przechowuje dane strumieniowe i można je podzielić jako Tematy. Temat będzie miał wiele partycji, aby mogło obsługiwać dowolną ilość danych. Możemy również mieć wiele replików dla odporności na usterki HDFS. W klastrze Kafka broker jest komponentem, który przechowuje opublikowane dane.

Zookeeper to obowiązkowa usługa do uruchomienia Kafka klaster, ponieważ jest używany do zarządzania koordynowaniem brokerów Kafka. Zookeeper odgrywa kluczową rolę między producentem a konsumentem, gdzie jest odpowiedzialny za utrzymanie stanu wszystkich brokerów.

W tym artykule wyjaśnimy, jak zainstalować Apache Kafka w jednym węźle Centos 7 Lub RHEL 7.

Instalowanie Apache Kafka w Centos 7

1. Najpierw musisz zainstalować Jawa w twoim systemie do uruchomienia Apache Kafka bez żadnych błędów. Więc zainstaluj domyślną dostępną wersję Jawa używając następującego polecenia Yum i zweryfikuj Jawa Wersja jak pokazano.

# Yum -y instaluj java -1.8.0 -openjdk # java -version
Sprawdź wersję Java

2. Następnie pobierz najnowszą stabilną wersję Apache Kafka z oficjalnej strony internetowej lub użyj następującego polecenia WGET, aby pobrać ją bezpośrednio i wyodrębnić.

# wget https: // lusterka.estointernet.in/apache/kafka/2.7.0/kafka_2.13-2.7.0.TGZ # tar -xzf kafka_2.13-2.7.0.TGZ

3. Utwórz symboliczny link dla Kafka Pakiet, a następnie dodaj ścieżkę środowiska Kafka do .bash_profile plik, a następnie zainicjuj go, jak pokazano.

# ln -s kafka_2.13-2.7.0 kafka # echo "Eksport ścieżka = $ ścieżka:/root/kafka_2.13-2.7.0/bin ">> ~/.bash_profile # Źródło ~/.bash_profile

4. Następnie zacznij Zookeeper, który jest wbudowany z Kafka pakiet. Ponieważ jest to klaster pojedynczego węzła, możesz uruchomić Zookeeper z domyślnymi właściwościami.

# Zookeeper-Server-Start.sh -daemon/root/kafka/config/zookeeper.nieruchomości

5. Potwierdzić, czy Zookeeper jest dostępny, czy po prostu przez Telnet Do Zookeeper Port 2181.

# Telnet LocalHost 2181
Sprawdź port Zookeeper

6. Zacząć Kafka z domyślnymi właściwościami. 

# Kafka-Server-Start.sh -daemon/root/kafka/config/serwer.nieruchomości
Rozpocznij usługę Kafka

7. Potwierdzić, czy Kafka jest dostępny lub nie przez telnet do portu Kafka 9092

# Telnet LocalHost 9092
Sprawdź port Kafka

8. Następnie utwórz przykładowy temat.

# Kafka-Topics.SH-Create --zookeeper LocalHost: 2181-Odreplikacja Factor 1-Partions 1-Topic Tecmint
Utwórz temat w Kafka

9. Wypisz utworzony temat.

# Kafka-Topics.sh -zookeeper LocalHost: 2181 -List
Lista temat w Kafka
Wniosek

W tym artykule widzieliśmy, jak zainstalować klaster pojedynczego węzła Kafka Centos 7. W następnym artykule zobaczymy, jak zainstalować klaster Kafka wieloosobowy.