Giunsa ang Pag-install sa Apache Kafka sa CentOS/RHEL 7

Ang Apache Kafka usa ka kusgan nga makina sa pagmemensahe, nga kaylap nga gigamit sa mga proyekto sa BigData ug ang siklo sa kinabuhi sa Data Analytics. Kini usa ka Open-source nga plataporma aron magtukod mga real-time nga data streaming pipelines. Kini usa ka gipang-apod-apod nga publish-subscribe nga plataporma nga adunay Kasaligan, Scalability, ug Durability.

Mahimo natong adunay Kafka isip usa ka standalone o isip usa ka cluster. Gitipigan sa Kafka ang streaming data, ug mahimo kini nga kategorya nga Mga Hilisgutan. Ang Hilisgutan adunay daghang mga partisyon aron kini makadumala sa usa ka arbitraryong kantidad sa datos. Usab, mahimo kaming adunay daghang mga replika alang sa dili pagtugot sa sayup sama sa among naa sa HDFS. Sa usa ka cluster sa Kafka, ang broker usa ka sangkap nga nagtipig sa gipatik nga datos.

Ang Zookeeper usa ka mandatory nga serbisyo sa pagpadagan sa usa ka Kafka cluster, tungod kay kini gigamit alang sa pagdumala sa co-ordinating sa Kafka brokers. Ang Zookeeper adunay hinungdanon nga papel tali sa prodyuser ug konsumidor diin responsable kini sa pagpadayon sa kahimtang sa tanan nga mga broker.

Niini nga artikulo, among ipasabut kung giunsa ang pag-install sa Apache Kafka sa usa ka node CentOS 7 o RHEL 7.

Pag-instalar sa Apache Kafka sa CentOS 7

1. Una, kinahanglan nimo nga i-install ang Java sa imong sistema aron makadagan ang Apache Kafka nga wala’y mga sayup. Busa, i-install ang default nga magamit nga bersyon sa Java gamit ang mosunod nga yum command ug pamatud-i ang bersyon sa Java sama sa gipakita.

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

2. Sunod, i-download ang pinakabag-o nga stable nga bersyon sa Apache Kafka gikan sa opisyal nga website o gamita ang mosunod nga wget command aron direktang i-download kini ug makuha kini.

# 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. Paghimo ug simbolikong sumpay para sa kafka package, unya idugang ang Kafka environment path sa .bash_profile file ug dayon i-initialize kini sama sa gipakita.

# 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. Sunod, sugdi ang Zookeeper, nga adunay built-in nga Kafka package. Tungod kay kini usa ka node cluster, mahimo nimong sugdan ang zookeeper nga adunay default nga mga kabtangan.

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

5. I-validate kung ang zookeeper ma-access o dili pinaagi lang sa telnet sa Zookeeper port 2181.

# telnet localhost 2181

6. Sugdi ang Kafka sa mga default nga kabtangan niini.

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

7. I-validate kung ang Kafka ma-access o dili pinaagi lang sa telnet sa Kafka port 9092

# telnet localhost 9092

8. Sunod, paghimo ug sampol nga topiko.

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

9. Ilista ang topiko nga nahimo.

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

Niini nga artikulo, among nakita kung giunsa ang pag-install sa usa ka Single node Kafka cluster sa CentOS 7. Atong makita kung giunsa ang pag-install sa usa ka multinode Kafka Cluster sa sunod nga artikulo.