ວິທີການຕິດຕັ້ງ Apache Kafka ໃນ CentOS / RHEL 7

Apache Kafka ແມ່ນເຄື່ອງຈັກສົ່ງຂໍ້ຄວາມທີ່ມີປະສິດທິພາບ, ເຊິ່ງຖືກ ນຳ ໃຊ້ຢ່າງກວ້າງຂວາງໃນໂຄງການ BigData ແລະວົງຈອນຊີວິດຂອງການວິເຄາະຂໍ້ມູນ. ມັນແມ່ນເວທີ Open-source ເພື່ອສ້າງທໍ່ສົ່ງຂໍ້ມູນໃນເວລາຈິງ. ມັນແມ່ນແພລະຕະຟອມເຜີຍແຜ່ການສະ ໝັກ - ແຈກຈ່າຍທີ່ມີຄວາມ ໜ້າ ເຊື່ອຖື, ຂະ ໜາດ, ແລະຄວາມທົນທານ.

ພວກເຮົາສາມາດມີ Kafka ເປັນຕົວເລືອກຫລືເປັນກຸ່ມ. Kafka ເກັບຂໍ້ມູນ streaming, ແລະມັນສາມາດຖືກຈັດປະເພດເປັນຫົວຂໍ້. ຫົວຂໍ້ດັ່ງກ່າວຈະມີສ່ວນທີ່ ຈຳ ນວນ ໜຶ່ງ ເພື່ອໃຫ້ສາມາດຈັດການກັບ ຈຳ ນວນຂໍ້ມູນທີ່ຕົນເອງມັກ. ພ້ອມກັນນີ້, ພວກເຮົາສາມາດມີແບບ ຈຳ ລອງຫຼາຍແບບ ສຳ ລັບຄວາມຜິດທີ່ພວກເຮົາ ກຳ ລັງມີຢູ່ໃນ HDFS. ໃນກຸ່ມບ້ານ Kafka, ນາຍຫນ້າແມ່ນສ່ວນປະກອບທີ່ເກັບຂໍ້ມູນທີ່ເຜີຍແຜ່.

Zookeeper ແມ່ນບໍລິການທີ່ ຈຳ ເປັນທີ່ຈະຕ້ອງ ດຳ ເນີນງານກຸ່ມບ້ານ Kafka, ຍ້ອນວ່າມັນຖືກ ນຳ ໃຊ້ໃນການຄຸ້ມຄອງການຮ່ວມມືຂອງບັນດານາຍ ໜ້າ Kafka. Zookeeper ມີບົດບາດ ສຳ ຄັນລະຫວ່າງຜູ້ຜະລິດແລະຜູ້ບໍລິໂພກເຊິ່ງມັນມີ ໜ້າ ທີ່ຮັບຜິດຊອບໃນການຮັກສາສະພາບຂອງບັນດານາຍ ໜ້າ.

ໃນບົດຂຽນນີ້, ພວກເຮົາຈະອະທິບາຍວິທີການຕິດຕັ້ງ Apache Kafka ໃນ node CentOS 7 ຫຼື RHEL 7 ດຽວ.

ຕິດຕັ້ງ Apache Kafka ໃນ CentOS 7

1. ທຳ ອິດທ່ານ ຈຳ ເປັນຕ້ອງຕິດຕັ້ງ Java ໃນລະບົບຂອງທ່ານເພື່ອ ດຳ ເນີນການ Apache Kafka ໂດຍບໍ່ມີຂໍ້ຜິດພາດໃດໆ. ດັ່ງນັ້ນ, ຕິດຕັ້ງ Java ເວີຊັນທີ່ມີໃນຕອນຕົ້ນໂດຍໃຊ້ ຄຳ ສັ່ງ yum ຕໍ່ໄປນີ້ແລະກວດສອບເວີຊັນ Java ດັ່ງທີ່ສະແດງໄວ້.

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

2. ຕໍ່ໄປ, ດາວໂຫລດເວີຊັນທີ່ ໝັ້ນ ຄົງທີ່ສຸດຂອງ Apache Kafka ຈາກເວັບໄຊທ໌ທາງການຫລືໃຊ້ ຄຳ ສັ່ງ wget ຕໍ່ໄປນີ້ເພື່ອດາວໂຫລດໂດຍກົງແລະສະກັດເອົາ.

# 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. ສ້າງລິ້ງ ສຳ ລັບສັນຍາລັກ kafka, ຫຼັງຈາກນັ້ນຕື່ມເສັ້ນທາງສະພາບແວດລ້ອມ Kafka ເຂົ້າໃນແຟ້ມ .bash_profile ແລະຫຼັງຈາກນັ້ນເລີ່ມຕົ້ນຕາມທີ່ສະແດງ.

# 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. ຕໍ່ໄປ, ເລີ່ມຕົ້ນ Zookeeper, ເຊິ່ງມາພ້ອມກັບຊຸດ Kafka. ເນື່ອງຈາກວ່າມັນເປັນກຸ່ມຂອງກຸ່ມດຽວ, ທ່ານສາມາດເລີ່ມຕົ້ນ zookeeper ດ້ວຍຄຸນສົມບັດເລີ່ມຕົ້ນ.

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

5. ກວດສອບຄວາມຖືກຕ້ອງບໍ່ວ່າຈະເປັນ zookeeper ສາມາດເຂົ້າເຖິງໄດ້ຫລືບໍ່ໂດຍພຽງແຕ່ໂທລະສັບໄປຫາທີ່ Port Zookeeper 2181.

# telnet localhost 2181

6. ເລີ່ມຕົ້ນ Kafka ດ້ວຍຄຸນສົມບັດເລີ່ມຕົ້ນ.

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

7. ກວດສອບຄວາມຖືກຕ້ອງວ່າ Kafka ສາມາດເຂົ້າເຖິງໄດ້ຫຼືບໍ່ໂດຍພຽງແຕ່ໂທລະສັບໄປຫາທີ່ Port Kafka 9092

# telnet localhost 9092

8. ຕໍ່ໄປ, ສ້າງຫົວຂໍ້ຕົວຢ່າງ.

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

9. ຂຽນຫົວຂໍ້ທີ່ສ້າງຂື້ນ.

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

ໃນບົດຂຽນນີ້, ພວກເຮົາໄດ້ເຫັນວິທີການຕິດຕັ້ງ clone ດຽວ node Kafka ໃນ CentOS 7. ພວກເຮົາຈະເຫັນວິທີການຕິດຕັ້ງ Clin multinode Kafka Cluster ໃນບົດຄວາມຕໍ່ໄປ.