Apache Kafka

Các tập tin và thư mục quan trọng

• Thư mục cài đặt chính của Kafka: /opt/kafka
• Tệp cấu hình Kafka broker: /opt/kafka/config/server.properties
• Thư mục nhật ký Kafka (nhật ký broker, sự kiện được lưu giữ): /opt/kafka/logs
• Các tệp nhị phân Kafka và công cụ CLI (kafka-topics.sh, kafka-console-producer.sh, vân vân.): /opt/kafka/bin
• Đơn vị dịch vụ Systemd để quản lý Kafka: /etc/systemd/system/kafka.service

Dịch vụ Kafka

sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka

Tạo chủ đề

/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

Kiểm tra chi tiết chủ đề:

/opt/kafka/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

Sự kiện sản xuất (Thông báo)

/opt/kafka/bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

Mỗi sự kiện trên một dòng.

Nhấn Ctrl+C để thoát ra.

Sự kiện tiêu thụ

/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

Nhấn Ctrl+C để ngừng đọc.

Sự kiện có thể được nhiều máy khách sử dụng nhiều lần.

Nhật ký & Khắc phục sự cố

• Nhật ký Kafka: /opt/kafka/logs
• Tạp chí Systemd: sudo journalctl -u kafka -f
• Đảm bảo các cảng 9092 (môi giới) và 9093 (Bộ điều khiển) đang mở.