Kafka连接问题Ubuntu怎么排查

在Ubuntu上排查Kafka连接问题可按以下步骤进行：

1. 检查服务状态

   • 确保Kafka和Zookeeper服务已启动：

     sudo systemctl status kafka  
     sudo systemctl status zookeeper  
     

     若未启动，使用 sudo systemctl start kafka 启动服务。

2. 验证配置文件

   • 检查Kafka配置文件 /etc/kafka/server.properties：
     • 确保 listeners 和 advertised.listeners 配置正确（如 PLAINTEXT://localhost:9092）。
     • 确认 zookeeper.connect 指向正确的Zookeeper地址。
   • 检查客户端配置（如Java代码或工具）的 bootstrap.servers 是否与Kafka配置一致。

3. 测试网络连通性

   • 使用 ping 测试Kafka节点IP可达性：

     ping <kafka-broker-ip>  
     

   • 使用 telnet 或 nc 测试端口是否开放：

     telnet <kafka-broker-ip> 9092  
     # 或  
     nc -zv <kafka-broker-ip> 9092  
     

4. 排查防火墙与安全组

   • 检查Ubuntu防火墙（UFW）是否允许Kafka端口（默认9092）：

     sudo ufw status  
     sudo ufw allow 9092  
     

   • 若为云服务器，需确认安全组规则已放行对应端口。

5. 查看日志与资源状态

   • 查看Kafka日志 /var/log/kafka/server.log，定位错误信息（如端口冲突、权限不足等）。
   • 检查磁盘空间和内存使用情况：

     df -h  
     free -h  
     

     确保Kafka数据目录所在磁盘有足够空间。

6. 处理版本与依赖问题

   • 确保客户端库版本与Kafka服务端版本兼容。
   • 若使用安全认证（如SSL/SASL），检查客户端配置是否包含正确的证书、用户名/密码。

7. 使用工具辅助诊断

   • 通过Kafka自带命令行工具测试连接：

     # 查看Topic列表  
     kafka-topics.sh --bootstrap-server <broker-ip>:9092 --list  
     # 生产/消费测试  
     kafka-console-producer.sh --bootstrap-server <broker-ip>:9092 --topic test  
     kafka-console-consumer.sh --bootstrap-server <broker-ip>:9092 --topic test --from-beginning  
     ```。  
     
     

参考来源：