![Hoe download en installeer ik Windows 10 21H2 Update Preview](/f/bf99068501edce47033166b9b70986ef.jpg?width=100&height=100)
Apache Kafka is een krachtige berichten-engine, die veel wordt gebruikt in BigData projecten en de Gegevensanalyse levenscyclus. Het is een open-sourceplatform om realtime pijplijnen voor gegevensstreaming te bouwen. Het is een gedistribueerd platform voor publiceren en abonneren met betrouwbaarheid, schaalbaarheid en duurzaamheid.
We kunnen hebben Kafka als standalone of als cluster. Kafka slaat de streaminggegevens op en kan worden gecategoriseerd als: Onderwerpen. De Onderwerp zal een aantal partities hebben, zodat het een willekeurige hoeveelheid gegevens kan verwerken. We kunnen ook meerdere replica's hebben voor fouttolerantie zoals we hebben in HDFS. In een Kafka-cluster is de broker een component die de gepubliceerde gegevens opslaat.
Zookeeper is een verplichte dienst om een Kafka cluster, aangezien het wordt gebruikt voor het beheer van de coördinatie van de Kafka-makelaars. Zookeeper speelt een sleutelrol tussen producent en consument waar het verantwoordelijk is voor het in stand houden van de staat van alle makelaars.
In dit artikel zullen we uitleggen hoe te installeren Apache Kafka in een enkele knoop CentOS 7 of RHEL 7.
1. Eerst moet je installeren Java op uw systeem om uit te voeren Apache Kafka zonder fouten. Installeer dus de standaard beschikbare versie van Java met behulp van het volgende: jammie commando en verifieer de Java versie zoals afgebeeld.
# yum -y installeer java-1.8.0-openjdk. # java-versie.
2. Download vervolgens de meest recente stabiele versie van Apache Kafka van de officiële website of gebruik het volgende: wget commando om het direct te downloaden en uit te pakken.
# wget https://mirrors.estointernet.in/apache/kafka/2.7.0/kafka_2.13-2.7.0.tgz # tar -xzf kafka_2.13-2.7.0.tgz
3. Maak een symbolische link voor kafka pakket en voeg vervolgens het Kafka-omgevingspad toe aan .bash_profile
bestand en initialiseer het vervolgens zoals weergegeven.
# ln -s kafka_2.13-2.7.0 kafka. # echo "export PATH=$PATH:/root/kafka_2.13-2.7.0/bin" >> ~/.bash_profile. # bron ~/.bash_profile.
4. Start vervolgens de Dierentuinmedewerker, die ingebouwd wordt met de Kafka pakket. Omdat het een cluster met één knooppunt is, kunt u de dierenverzorger starten met standaardeigenschappen.
# zookeeper-server-start.sh -daemon /root/kafka/config/zookeeper.properties.
5. Valideer of de dierenverzorger toegankelijk is of niet door simpelweg telnet tot Dierentuinmedewerker haven 2181.
# telnet localhost 2181.
6. Start de Kafka met zijn standaard eigenschappen.
# kafka-server-start.sh -daemon /root/kafka/config/server.properties.
7. Valideer of de Kafka is toegankelijk of niet door simpelweg telnet naar Kafka-poort 9092
# telnet localhost 9092.
8. Maak vervolgens een voorbeeldonderwerp.
# kafka-topics.sh --create --zookeeper localhost: 2181 --replication-factor 1 --partitions 1 --topic tecmint.
9. Maak een lijst van het gecreëerde onderwerp.
# kafka-topics.sh --zookeeper localhost: 2181 --list.
In dit artikel hebben we gezien hoe u een Kafka-cluster met één knooppunt installeert in CentOS 7. In het volgende artikel zullen we zien hoe u een multinode Kafka-cluster installeert.