以下是Kafka在CentOS上的故障排查指南:
- 查看日志:检查Kafka安装目录下
logs文件夹中的日志文件,定位错误信息。 - 检查配置文件:确认
server.properties中broker.id唯一、listeners/advertised.listeners配置正确,zookeeper.connect指向正确地址。 - 端口占用检查:使用
netstat -tuln | grep 端口号查看Kafka端口(默认9092)是否被占用,冲突时修改配置或停止占用进程。 - Zookeeper状态:确保Zookeeper服务已启动,通过
systemctl status zookeeper查看状态,异常时启动服务并检查其日志。 - 系统资源与权限:
- 用
df -h检查磁盘空间是否充足,确保log.dirs所在分区有足够空间。 - 确保Kafka运行用户对配置文件、数据目录有读写权限,可通过
chown命令调整。
- 用
- 防火墙与网络:开放Kafka端口(默认9092),使用
firewall-cmd命令添加规则,并检查网络连通性(如ping、telnet)。 - 服务管理:通过
systemctl命令管理Kafka服务(启动、停止、重启、开机自启),确保服务状态正常。 - 环境依赖:确认已安装正确版本的JDK(Kafka 2.x+需Java 8+),通过
java -version验证。
若以上步骤无法解决,可参考Kafka官方文档或社区论坛,提供详细日志和配置信息进一步排查。