重要文件和目录
- Kafka 主安装目录:
/opt/kafka - 卡夫卡经纪人配置文件:
/opt/kafka/config/server.properties - Kafka日志目录(代理日志、保留事件):
/opt/kafka/logs - Kafka 二进制文件和 CLI 工具(
kafka-topics.sh,kafka-console-producer.sh, ETC。):/opt/kafka/bin - 用于管理Kafka的Systemd服务单元:
/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 - 系统日志:
sudo journalctl -u kafka -f - 确保端口
9092(经纪人)和9093(控制器)已打开。