以下是Kafka在CentOS上的故障排查步骤:
systemctl status kafka和systemctl status zookeeper确认服务是否正常运行。logs文件夹中,通过tail -n 500 server.log查看错误信息。server.properties中broker.id(唯一)、listeners(端口配置)、advertised.listeners(客户端连接地址)、zookeeper.connect(ZK地址)等参数是否正确。netstat -tuln | grep 9092确认端口未被占用,通过sudo firewall-cmd --add-port=9092/tcp --permanent开放防火墙端口。df -h),JVM内存配置合理,Kafka用户对数据目录(如/var/lib/kafka)有读写权限。echo stat | nc zookeeper_ip 2181测试连接。listeners配置并重启Kafka。broker.id重复、路径错误等问题。ping/telnet),确保防火墙规则正确。kafka-console-consumer/producer测试消息收发,或通过ELK Stack分析日志。若以上步骤无法解决,建议记录详细日志并在Kafka社区或Stack Overflow寻求帮助。