เริ่มต้นใช้งาน Apache Kafka
ก่อนติดตั้ง Apache Kafka คุณต้องติดตั้ง Java และบัญชีผู้ใช้ที่มีสิทธิ์ sudo นอกจากนี้ ขอแนะนำให้มี RAM ขนาด 2GB ขึ้นไปเพื่อให้ Kafka ทำงานได้อย่างถูกต้อง
ขั้นตอนต่อไปนี้จะแนะนำวิธีการติดตั้ง Apache Kafka
การติดตั้ง Java
จำเป็นต้องใช้ Java เพื่อติดตั้ง Kafka ตรวจสอบว่า Ubuntu ของคุณมี Java ติดตั้งอยู่หรือไม่โดยตรวจสอบเวอร์ชันโดยใช้คำสั่งต่อไปนี้:
$ จาวา --รุ่น
หากไม่ได้ติดตั้ง Java ให้ใช้คำสั่งต่อไปนี้เพื่อติดตั้ง Java OpenJDK
$ sudo ฉลาด ติดตั้ง default-jdk
การสร้างบัญชีผู้ใช้
เมื่อติดตั้ง Java แล้ว ให้สร้างบัญชีผู้ใช้ที่ไม่ใช่รูท เราต้องให้สิทธิ์ sudo บางอย่างด้วยการเพิ่มผู้ใช้ในกลุ่ม sudo โดยใช้คำสั่งต่อไปนี้:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
เข้าสู่ระบบบัญชีผู้ใช้ที่สร้างขึ้นใหม่
การติดตั้งคาฟคา
คุณต้องดาวน์โหลด Apache Kafka ล่าสุดจากหน้าดาวน์โหลดอย่างเป็นทางการ ดาวน์โหลดไฟล์ไบนารีโดยใช้ wget คำสั่งดังที่แสดงต่อไปนี้:
$ wget https: // downloads.apache.org / คาฟคา / 3.2.3 / kafka_2.12-3.2.3.tgz 
เมื่อดาวน์โหลดไฟล์ไบนารีแล้ว ให้แตกไฟล์โดยใช้ปุ่ม ใช้เวลา คำสั่งและย้ายไดเร็กทอรีที่แยกออกมาไปที่ /opt/คาฟคา.
ถัดไป สร้าง สคริปต์ systemd สำหรับ ผู้ดูแลสวนสัตว์ และ คาฟคา บริการที่ช่วยในการเริ่มต้นและหยุดบริการ
ใช้ตัวแก้ไขที่เลือกเพื่อสร้างสคริปต์ systemd และวางเนื้อหาต่อไปนี้ เริ่มต้นด้วย Zookeeper:
$ sudo นาโน / ฯลฯ / systemd / ระบบ / Zookeeper.serviceวางสิ่งต่อไปนี้:
[ หน่วย ]คำอธิบาย =เซิร์ฟเวอร์ Apache Zookeeper
เอกสาร =http: // zookeeper.apache.org
กำหนดให้มี =network.target รีโมท fs.target
หลังจาก =network.target รีโมท fs.target
[ บริการ ]
พิมพ์ =ง่าย
ExecStart = / เลือก / คาฟคา / บิน / Zookeeper-server-start.sh / เลือก / คาฟคา / config / zookeeper.properties
ExecStop = / เลือก / คาฟคา / บิน / zookeeper-server-stop.sh
เริ่มต้นใหม่ =ผิดปกติ
[ ติดตั้ง ]
WantedBy =ผู้ใช้หลายคน.target
บันทึกไฟล์. สร้างไฟล์ systemd สำหรับ Kafka และวางเนื้อหาต่อไปนี้:
เมื่อวาง ตรวจสอบให้แน่ใจว่าคุณได้กำหนดเส้นทางที่ถูกต้องสำหรับ Java ที่คุณติดตั้งในระบบของคุณ
[ หน่วย ]คำอธิบาย =เซิร์ฟเวอร์ Apache Kafka
เอกสาร =http: // kafka.apache.org / document.html
กำหนดให้มี =ผู้ดูแลสวนสัตว์.บริการ
[ บริการ ]
พิมพ์ =ง่าย
สิ่งแวดล้อม = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / เลือก / คาฟคา / บิน / kafka-server-start.sh / เลือก / คาฟคา / config / server.properties
ExecStop = / เลือก / คาฟคา / บิน / kafka-server-stop.sh
เริ่มต้นใหม่ =ผิดปกติ
[ ติดตั้ง ]
WantedBy =ผู้ใช้หลายคน.target
เมื่อเสร็จแล้ว ใช้การเปลี่ยนแปลงโดยโหลด systemd daemon ใหม่:
ถัดไป เปิดใช้งานบริการ Zookeeper และเริ่มต้นโดยใช้คำสั่งต่อไปนี้:
$ sudo systemctl เริ่ม zookeepe < แข็งแกร่ง > r แข็งแกร่ง >
คุณต้องทำเช่นเดียวกันสำหรับ Kafka:
$ sudo systemctl start kafka
เมื่อคุณเริ่มบริการ คุณสามารถตรวจสอบสถานะก่อนที่เราจะสร้างหัวข้อใน Kafka
ข้อดีของ Kafka คือมีหลายสคริปต์ที่คุณสามารถใช้ได้
มาสร้างหัวข้อใหม่ชื่อ linuxhint1 ใช้ kafka-topics.sh สคริปต์ที่มีหนึ่งพาร์ติชันและการจำลองแบบ ใช้คำสั่งต่อไปนี้:
$ sudo -ใน linuxhint / เลือก / คาฟคา / บิน / kafka-topics.sh --สร้าง --bootstrap-เซิร์ฟเวอร์ localhost: 9092 --replication-factor 1 --พาร์ทิชัน 1 --หัวข้อ linuxhint1 
โปรดทราบว่าหัวข้อของเราถูกสร้างขึ้น เราสามารถเห็นข้อความก่อนหน้าเพื่อยืนยันได้
อีกวิธีหนึ่ง คุณสามารถระบุหัวข้อที่มีได้โดยใช้ปุ่ม -รายการ ตัวเลือกในคำสั่งต่อไปนี้ ควรส่งคืนหัวข้อที่เราสร้าง:S
$ sudo -ใน linuxhint / เลือก / คาฟคา / บิน / kafka-topics.sh --รายการ --bootstrap-เซิร์ฟเวอร์ localhost: 9092 
ด้วยการสร้างหัวข้อ Kafka คุณสามารถเริ่มเขียนข้อมูลสตรีมบน Kafka-console-producer.sh และตรวจสอบว่าสะท้อนอยู่ใน .ของคุณหรือไม่ Consumer.sh.
เปิดเชลล์ของคุณและเข้าถึงหัวข้อที่เราสร้างโดยใช้ Producer.sh ดังที่แสดงดังต่อไปนี้:
$ sudo -ใน linuxhint / เลือก / คาฟคา / บิน / kafka-console-producer.sh --นายหน้า-รายชื่อ localhost: 9092 --หัวข้อ linuxhint1 
ถัดไป เปิดเชลล์อื่นและเข้าถึงหัวข้อ Kafka โดยใช้ Consumer.sh
เมื่อเปิดเชลล์ทั้งสองไว้ คุณสามารถส่งข้อความบนคอนโซลผู้ผลิตได้ สิ่งที่คุณพิมพ์จะสะท้อนให้เห็นในคอนโซลผู้บริโภคเพื่อยืนยันว่า Apache Kafka ของเราใช้งานได้
บทสรุป
ด้วยคู่มือนี้ คุณมีขั้นตอนทั้งหมดที่คุณสามารถปฏิบัติตามเพื่อติดตั้ง Apache Kafka ใน Ubuntu 22.04 ของคุณ หวังว่าคุณจะทำตามแต่ละขั้นตอนและติดตั้ง Apache Kafka และสร้างหัวข้อเพื่อดำเนินการผลิตผู้บริโภคและผู้ผลิตอย่างง่าย คุณสามารถใช้สิ่งเดียวกันนี้ในการผลิตขนาดใหญ่