Bii o ṣe le Fi Kafka Apache sii ni CentOS/RHEL 7

Apache Kafka jẹ ẹrọ fifiranṣẹ ti o lagbara, eyiti o lo ni ibigbogbo ninu awọn iṣẹ akanṣe BigData ati iyika igbesi aye Awọn atupale Data. O jẹ pẹpẹ orisun-orisun lati kọ awọn opo gigun ti omi ṣiṣan gidi-akoko. O jẹ pẹpẹ atẹjade ti a pin kaakiri pẹlu igbẹkẹle, Scalability, ati Agbara.

A le ni Kafka gege bi adashe tabi bi iṣupọ kan. Kafka tọju data ṣiṣan silẹ, ati pe o le ṣe tito lẹtọ bi Awọn koko. Koko naa yoo ni ọpọlọpọ awọn ipin ki o le mu iye data lainidii. Pẹlupẹlu, a le ni awọn ẹda pupọ fun ifarada ifarada bi a ṣe ni HDFS. Ninu iṣupọ Kafka kan, alagbata jẹ paati ti o tọju data ti a tẹjade.

Zookeeper jẹ iṣẹ ti o jẹ dandan lati ṣiṣẹ iṣupọ Kafka kan, bi o ti lo fun ṣiṣakoso ifowosowopo awọn alagbata Kafka. Zookeeper ṣe ipa pataki laarin olupilẹṣẹ ati alabara nibiti o jẹ iduro fun mimu ipo ti gbogbo awọn alagbata.

Ninu nkan yii, a yoo ṣalaye bi a ṣe le fi Apache Kafka sori ẹrọ ni oju ipade kan CentOS 7 tabi RHEL 7.

Fifi Apache Kafka sii ni CentOS 7

1. Ni akọkọ, o nilo lati fi Java sori ẹrọ lori ẹrọ rẹ lati ṣiṣe Apache Kafka laisi awọn aṣiṣe eyikeyi. Nitorinaa, fi sori ẹrọ ẹya aiyipada ti Java nipa lilo pipaṣẹ yum atẹle ki o jẹrisi ẹya Java bi o ti han.

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

2. Itele, ṣe igbasilẹ ẹya iduroṣinṣin to ṣẹṣẹ ti Apache Kafka lati oju opo wẹẹbu osise tabi lo pipaṣẹ wget atẹle lati gba lati ayelujara taara ati jade.

# 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. Ṣẹda ọna asopọ aami fun package kafka, lẹhinna ṣafikun ọna ayika Kafka si .bash_profile faili ati lẹhinna bẹrẹ bi o ti han.

# 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. Itele, bẹrẹ Zookeeper, eyiti o wa pẹlu rẹ pẹlu package Kafka. Niwọn bi o ti jẹ iṣupọ ipade ẹyọkan, o le bẹrẹ zookeeper pẹlu awọn ohun-ini aiyipada.

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

5. Ṣe idaniloju boya oluṣọ zoo wa ni wiwọle tabi kii ṣe nipa tẹlifoonu si ibudo Zookeeper 2181.

# telnet localhost 2181

6. Bẹrẹ Kafka pẹlu awọn ohun-ini aiyipada rẹ.

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

7. Ṣe afihan boya Kafka wa ni wiwọle tabi kii ṣe nipa tẹlifoonu si ibudo Kafka 9092

# telnet localhost 9092

8. Nigbamii, ṣẹda akọle apẹẹrẹ.

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

9. Ṣe atokọ koko ti a ṣẹda.

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

Ninu àpilẹkọ yii, a ti rii bii a ṣe le fi iṣupọ Kanka node Kafka kan sii ni CentOS 7. A yoo rii bi a ṣe le fi multinode Kafka Cluster sori ẹrọ ni nkan ti n bọ.