CentOS Kafka配置常见问题及解决

一、基础配置问题

1. 端口冲突

   • 现象：Kafka/Zookeeper无法启动，提示端口被占用。
   • 解决：检查server.properties中listeners和advertised.listeners配置的端口（默认9092），使用netstat -tuln确认端口是否被占用，修改为未使用的端口并重启服务。

2. 配置文件路径或权限错误

   • 现象：启动时报“配置文件不存在”或“权限不足”。
   • 解决：确保server.properties路径正确，使用chmod -R 755赋予Kafka用户（如kafka）对配置文件和日志目录的读写权限。

3. ZooKeeper连接失败

   • 现象：Kafka启动时提示“ZooKeeper connection lost”。
   • 解决：检查ZooKeeper服务是否运行（systemctl status zookeeper），确认zookeeper.connect参数指向正确的ZooKeeper地址和端口，确保防火墙允许ZooKeeper端口（默认2181）。

二、网络与通信问题

1. 节点间通信异常

   • 现象：Broker无法加入集群，或生产者/消费者连接失败。
   • 解决：检查advertised.listeners是否配置为节点实际IP和端口，确保服务器间网络互通（ping测试），关闭防火墙或放行Kafka相关端口。

2. 跨机房同步延迟高

   • 现象：跨机房副本同步慢，ISR列表不稳定。
   • 解决：优先配置同机房副本优先同步，调整replica.socket.timeout.ms和replica.fetch.wait.max.ms参数，优化网络带宽。

三、性能与资源问题

1. 消息积压或延迟高

   • 现象：消费者滞后严重，队列堆积。
   • 解决：增加消费者数量或分区数（num.partitions），调整fetch.min.bytes和fetch.max.wait.ms优化拉取效率，升级Broker硬件或调整JVM堆内存（KAFKA_HEAP_OPTS）。

2. 磁盘空间不足

   • 现象：日志文件占满磁盘，导致写入失败。
   • 解决：配置log.retention.hours缩短日志保留时间，或通过log.dirs指定多个存储目录分散压力，定期清理旧日志。

四、权限与安全问题

1. 文件权限不足

   • 现象：Kafka无法读写数据目录或日志文件。
   • 解决：使用chown -R kafka:kafka /path/to/kafka/logs和chown -R kafka:kafka /path/to/kafka/data赋予Kafka用户权限。

2. 未启用安全认证

   • 现象：生产环境存在未授权访问风险。
   • 解决：配置SASL/SSL认证，修改server.properties中security.inter.broker.protocol为SASL_PLAINTEXT，并设置listener.name.sasl_plaintext.scram-sha-256等参数。

五、版本与日志问题

1. 版本兼容性问题

   • 现象：客户端与服务器版本不匹配，导致协议错误。
   • 解决：确保客户端与服务器使用相同主版本号（如Kafka 3.x客户端连接3.x服务器），参考官方兼容性矩阵。

2. 日志分析困难

   • 现象：日志文件过大或关键信息缺失。
   • 解决：配置日志切割（如log4j.appender.rolling.MaxFileSize），定期清理旧日志，使用kafka-log-dirs工具监控日志状态。

排查工具推荐

• 命令行工具：kafka-topics.sh（查看Topic状态）、kafka-consumer-groups.sh（监控消费组滞后）、jps（检查进程）。
• 监控工具：Prometheus+Grafana（监控集群指标）、ELK Stack（日志分析）。

提示：修改配置前建议备份原文件，优先在测试环境验证，避免直接修改生产环境参数。如问题持续，可通过Kafka官方社区或日志中的异常堆栈进一步定位。