Apache Kafka

File và thư mục quan trọng

• Thư mục cài đặt chính của Kafka: /opt/kafka
• File cấu hình Kafka broker: /opt/kafka/config/server.properties
• Thư mục log của Kafka (log broker, sự kiện được lưu giữ): /opt/kafka/logs
• Các file thực thi và công cụ CLI của Kafka (kafka-topics.sh, kafka-console-producer.sh, v.v.): /opt/kafka/bin
• Systemd service unit để 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 thông tin chi tiết của topic:

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

Gửi sự kiện (Messages)

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

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

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

Tiêu thụ Sự kiện

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

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

Các sự kiện có thể được tiêu thụ nhiều lần bởi nhiều client khác nhau.

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

• Nhật ký Kafka: /opt/kafka/logs
• Nhật ký Systemd: sudo journalctl -u kafka -f
• Đảm bảo cổng 9092 (broker) và 9093 (controller) đang mở.