以下是在Ubuntu上进行Kafka故障排查的常用方法:
检查服务状态
sudo systemctl status kafka
查看Kafka服务是否运行,未运行则启动:sudo systemctl start kafka
。sudo systemctl status zookeeper
。查看日志文件
/var/log/kafka/
,查看server.log
定位错误:sudo tail -f /var/log/kafka/server.log
。验证配置文件
/etc/kafka/server.properties
,重点关注listeners
、advertised.listeners
、zookeeper.connect
等配置是否正确。检查网络与端口
ping
和telnet
测试网络连通性及端口(默认9092)是否可达:telnet <broker-ip> 9092
。sudo netstat -tulnp | grep 9092
。监控硬件资源
df -h
检查磁盘空间,iostat -x 1 10
监控磁盘IO,top
查看CPU/内存使用情况。使用工具辅助排查
kafka-console-producer.sh
/kafka-console-consumer.sh
。kafka-topics.sh --describe --topic <topic-name> --bootstrap-server <broker-ip>:9092
。处理常见问题
server.properties
中listeners
配置或停止占用端口的进程。log.dirs
所在磁盘空间耗尽。参考官方文档与社区
说明:部分路径(如日志目录)可能因安装方式不同略有差异,可通过ps -ef | grep kafka
确认实际路径。