ไฟล์และไดเรกทอรีที่สำคัญ
- ไดเร็กทอรีการติดตั้งหลักของ Kafka:
/opt/kafka - ไฟล์การกำหนดค่าโบรกเกอร์ Kafka:
/opt/kafka/config/server.properties - ไดเรกทอรีบันทึกของ Kafka (บันทึกของโบรกเกอร์ กิจกรรมที่เก็บไว้):
/opt/kafka/logs - ไบนารี Kafka และเครื่องมือ CLI (
kafka-topics.sh,kafka-console-producer.shฯลฯ):/opt/kafka/bin - หน่วยบริการ Systemd สำหรับการจัดการ Kafka:
/etc/systemd/system/kafka.service
คาฟคา เซอร์วิส
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
สร้างกิจกรรม (ข้อความ)
/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 เพื่อหยุดอ่าน
เหตุการณ์สามารถใช้ได้หลายครั้งโดยไคลเอนต์หลายราย
บันทึกและการแก้ไขปัญหา
- บันทึกของคาฟคา:
/opt/kafka/logs - วารสาร Systemd:
sudo journalctl -u kafka -f - ตรวจสอบให้แน่ใจว่าพอร์ต
9092(นายหน้า) และ9093(ตัวควบคุม) เปิดอยู่
