排查Linux Kafka故障可按以下步骤进行:
systemctl status kafka
确认服务是否运行。/var/log/kafka/
目录下的日志(如server.log
),定位错误信息。server.properties
中broker.id
、listeners
、zookeeper.connect
等配置是否正确。ping
、telnet
或nc
命令验证Kafka节点间及与ZooKeeper的网络连通性。top
、htop
、df
等命令查看CPU、内存、磁盘使用情况,确保无资源瓶颈。zkServer.sh status
查看状态。netstat
或lsof
检查Kafka端口(如9092)是否被占用。kafka-topics.sh
、kafka-console-producer.sh
等命令测试主题和消息生产消费功能。若问题仍未解决,可参考官方文档或社区论坛进一步分析。