Kif Tinstalla Apache Kafka f'CentOS/RHEL 7

Apache Kafka hija magna ta 'messaġġi qawwija, li tintuża ħafna fi proġetti BigData u ċ-ċiklu tal-ħajja tad-Data Analytics. Hija pjattaforma Open-source biex tibni pipelines ta' streaming tad-dejta f'ħin reali. Hija pjattaforma mqassma ta 'pubblikazzjoni-abbonament b'Affidabbiltà, Skalabbiltà u Durabilità.

Nistgħu jkollna lil Kafka bħala waħdu jew bħala cluster. Kafka jaħżen id-dejta tal-istrimjar, u tista' tiġi kkategorizzata bħala Suġġetti. Is-Suġġett se jkun qed ikollu numru ta' diviżorji sabiex ikun jista' jimmaniġġja ammont arbitrarju ta' data. Ukoll, jista 'jkollna repliki multipli għal tolleranza għall-ħsarat kif qed ikollna fl-HDFS. Fi cluster Kafka, is-sensar huwa komponent li jaħżen id-dejta ppubblikata.

Zookeeper huwa servizz obbligatorju biex imexxi cluster Kafka, peress li jintuża għall-ġestjoni tal-koordinazzjoni tas-sensara Kafka. Zookeeper għandu rwol ewlieni bejn il-produttur u l-konsumatur fejn huwa responsabbli biex iżomm l-istat tas-sensara kollha.

F'dan l-artikolu, se nispjegaw kif tinstalla Apache Kafka f'nodu wieħed CentOS 7 jew RHEL 7.

Installazzjoni ta' Apache Kafka f'CentOS 7

1. L-ewwel, għandek bżonn tinstalla Java fis-sistema tiegħek biex tħaddem Apache Kafka mingħajr ebda żball. Allura, installa l-verżjoni default disponibbli ta 'Java billi tuża l-kmand yum li ġej u ivverifika l-verżjoni Java kif muri.

# yum -y install java-1.8.0-openjdk
# java -version

2. Sussegwentement, niżżel il-verżjoni stabbli l-aktar reċenti ta 'Apache Kafka mill-websajt uffiċjali jew uża l-kmand wget li ġej biex tniżżel direttament u estrattha.

# 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. Oħloq rabta simbolika għall-pakkett kafka, imbagħad żid il-mogħdija tal-ambjent Kafka mal-fajl .bash_profile u mbagħad inizjalizzaha kif muri.

# ln -s kafka_2.13-2.7.0 kafka
# echo "export PATH=$PATH:/root/kafka_2.13-2.7.0/bin" >> ~/.bash_profile
# source ~/.bash_profile

4. Sussegwentement, ibda l-Zookeeper, li jiġi inkorporat mal-pakkett Kafka. Peress li huwa cluster ta 'nodi wieħed, tista' tibda ż-zookeeper bi proprjetajiet default.

# zookeeper-server-start.sh -daemon /root/kafka/config/zookeeper.properties

5. Ivvalida jekk iż-zookeeper huwiex aċċessibbli jew le billi sempliċiment telnet għall-port Zookeeper 2181.

# telnet localhost 2181

6. Ibda l-Kafka bil-proprjetajiet default tagħha.

# kafka-server-start.sh -daemon /root/kafka/config/server.properties

7. Ivvalida jekk il-Kafka huwiex aċċessibbli jew le billi sempliċiment telnet għall-port Kafka 9092

# telnet localhost 9092

8. Sussegwentement, oħloq suġġett kampjun.

# kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic tecmint

9. Elenka s-suġġett maħluqa.

# kafka-topics.sh --zookeeper localhost:2181 --list

F'dan l-artikolu, rajna kif tinstalla cluster Kafka ta 'node Uniku f'CentOS 7. Se naraw kif tinstalla cluster Kafka multinode fl-artiklu li jmiss.