File và thư mục quan trọng
- Thư mục cài đặt Kafka chính:
/opt/kafka - Tệp cấu hình môi giới Kafka:
/opt/kafka/config/server.properties - Thư mục nhật ký Kafka (nhật ký môi giới, sự kiện được giữ lại):
/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
Tạo sự kiện (Tin nhắn)
/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 ra.
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 để ngừng đọc.
Sự kiện có thể được sử dụng nhiều lần bởi nhiều khách hàng.
Nhật ký & khắc phục sự cố
- Nhật ký Kafka:
/opt/kafka/logs - Tạp chí hệ thống:
sudo journalctl -u kafka -f - Đảm bảo cổng
9092(người môi giới) và9093(bộ điều khiển) đang mở.
