以下是在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确认实际路径。