以下是在Ubuntu上進行Kafka故障排查的常用方法:
檢查服務狀態
sudo systemctl status kafka查看Kafka服務是否運行,未運行則啟動:sudo systemctl start kafka。sudo systemctl status zookeeper。查看日志文件
/var/log/kafka/,查看server.log定位錯誤:sudo tail -f /var/log/kafka/server.log。驗證配置文件
/etc/kafka/server.properties,重點關注listeners、advertised.listeners、zookeeper.connect等配置是否正確。檢查網絡與端口
ping和telnet測試網絡連通性及端口(默認9092)是否可達:telnet <broker-ip> 9092。sudo netstat -tulnp | grep 9092。監控硬件資源
df -h檢查磁盤空間,iostat -x 1 10監控磁盤IO,top查看CPU/內存使用情況。使用工具輔助排查
kafka-console-producer.sh/kafka-console-consumer.sh。kafka-topics.sh --describe --topic <topic-name> --bootstrap-server <broker-ip>:9092。處理常見問題
server.properties中listeners配置或停止占用端口的進程。log.dirs所在磁盤空間耗盡。參考官方文檔與社區
說明:部分路徑(如日志目錄)可能因安裝方式不同略有差異,可通過ps -ef | grep kafka確認實際路徑。