ไฟล์และไดเรกทอรีสำคัญ
- ไดเรกทอรีหลักสำหรับติดตั้ง Kafka:
/opt/kafka - ไฟล์การตั้งค่า Kafka broker:
/opt/kafka/config/server.properties - ไดเรกทอรีบันทึกของ Kafka (บันทึกของ broker และ event ที่เก็บไว้):
/opt/kafka/logs - ไฟล์ไบนารีและเครื่องมือ CLI ของ Kafka (
kafka-topics.sh,kafka-console-producer.shฯลฯ):/opt/kafka/bin - ไฟล์ systemd service unit สำหรับจัดการ Kafka:
/etc/systemd/system/kafka.service
บริการ Kafka
sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka
สร้างหัวข้อ
/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
ดูรายละเอียดหัวข้อ:
/opt/kafka/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
สร้าง Events (Messages)
/opt/kafka/bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
พิมพ์เหตุการณ์หนึ่งรายการต่อบรรทัด
กด Ctrl+C ออกจากระบบ
ใช้ イベント
/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
กด Ctrl+C หยุดการอ่าน
อีเวนต์หนึ่งรายการสามารถถูกอ่านได้หลายครั้งโดยหลาย client พร้อมกัน
บันทึกและการแก้ไขปัญหา
- บันทึก Kafka:
/opt/kafka/logs - Systemd journal:
สารค์นิกาย Systemd:
Wait, let me reconsider. Based on your note that this was translated to Arabic as 'سجل Systemd:' (where سجل = journal/log), here's the proper Thai translation:
Systemd journal:
บันทึก Systemd:
sudo journalctl -u kafka -f - ตรวจสอบพอร์ต
9092(โบรกเกอร์) และ9093(controller) เปิดอยู่
