Linux Kafka故障如何排查

Linux Kafka故障排查步骤如下：

1. 检查服务状态：使用systemctl status kafka确认Kafka服务是否运行。
2. 查看日志文件：分析/var/log/kafka/目录下的日志（如server.log），定位错误信息。
3. 验证配置文件：检查server.properties中broker.id、listeners、zookeeper.connect等配置是否正确。
4. 测试网络连接：用ping、telnet或nc命令测试Kafka节点间网络连通性，确保端口（如9092）未被占用。
5. 监控硬件资源：通过top、df等命令查看CPU、内存、磁盘使用情况，确保资源充足。
6. 检查Zookeeper状态：确保Zookeeper服务正常运行，Kafka依赖其管理集群元数据。
7. 使用工具辅助排查：
   • 命令行工具：kafka-topics.sh查看主题状态，kafka-console-producer/consumer.sh测试生产消费。
   • 监控工具：Prometheus+Grafana监控集群指标，JMX监控JVM性能。
8. 处理常见问题：
   • 端口冲突：修改配置文件中端口或停止占用端口的进程。
   • 磁盘空间不足：清理数据或扩展存储，调整log.retention参数。
   • 版本兼容性问题：确保Kafka与Zookeeper等组件版本匹配。
9. 重启服务：在完成上述检查后，尝试重启Kafka服务systemctl restart kafka。

若问题仍未解决，可参考官方文档或社区论坛获取进一步支持。