重要文件与目录
- Kafka 主安装目录:
/opt/kafka - Kafka Broker 配置文件:
/opt/kafka/config/server.properties - Kafka 日志目录(Broker 日志及已保留事件):
/opt/kafka/logs - Kafka 可执行文件及 CLI 工具(
kafka-topics.sh,kafka-console-producer.sh等等):/opt/kafka/bin - 用于管理 Kafka 的 Systemd 服务单元:
/etc/systemd/system/kafka.service
Kafka 服务
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
查看 Topic 详情:
/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 停止阅读。
多个客户端可以对同一批事件进行多次消费。
日志和故障排除
- Kafka 日志:
/opt/kafka/logs - Systemd 日志
sudo journalctl -u kafka -f - 确保端口
9092(经纪商)及9093(controller)已开放。