如何检查Debian Kafka配置

在 Debian 上检查 Kafka 配置，通常要从 Kafka 本身的配置、运行环境、系统资源和日志 几个方面入手。下面按常见场景给你一个完整检查清单。

一、确认 Kafka 是否已安装并运行

1. 检查 Kafka 进程

ps -ef | grep kafka

或

pgrep -a java

Kafka 通常是 Java 进程，包含 kafka.Kafka。

2. 检查 Kafka 服务状态（如果用 systemd）

systemctl status kafka

如果没用 systemd，而是手动启动：

jps

二、检查 Kafka 配置文件

Kafka 的配置文件一般在：

/etc/kafka/

或

/opt/kafka/config/

核心配置文件

文件	作用
`server.properties`	Kafka Broker 主配置
`producer.properties`	生产者配置
`consumer.properties`	消费者配置
`zookeeper.properties`	ZooKeeper 配置（旧版本）

查看主配置

cat /etc/kafka/server.properties

常见关键项：

broker.id=0
listeners=PLAINTEXT://:9092
log.dirs=/var/lib/kafka/logs
zookeeper.connect=localhost:2181
num.partitions=1
offsets.topic.replication.factor=1

三、检查 Kafka 监听端口

1. 查看监听端口

ss -lntp | grep 9092

或

netstat -lntp | grep 9092

2. 测试端口是否可达

telnet localhost 9092

四、检查 Kafka 日志

1. Kafka 日志目录

常见位置：

/var/log/kafka/

或

/opt/kafka/logs/

2. 查看错误日志

tail -f /var/log/kafka/server.log

重点关注：

ERROR
FATAL
Connection refused
Broker may not be available

五、检查 Kafka 数据目录

cat /etc/kafka/server.properties | grep log.dirs

检查目录是否存在及权限：

ls -ld /var/lib/kafka/logs

确保 Kafka 用户有权限：

chown -R kafka:kafka /var/lib/kafka

六、检查 ZooKeeper / KRaft 状态

1. 如果使用 ZooKeeper

systemctl status zookeeper

端口检查：

ss -lntp | grep 2181

2. 如果使用 KRaft（Kafka 3.x+）

检查配置：

process.roles=broker,controller
node.id=1
controller.quorum.voters=1@localhost:9093

七、检查 Kafka 是否能正常工作

1. 创建 Topic

kafka-topics.sh --create \
  --topic test \
  --bootstrap-server localhost:9092 \
  --partitions 1 \
  --replication-factor 1

2. 查看 Topic

kafka-topics.sh --list --bootstrap-server localhost:9092

3. 生产 / 消费测试

kafka-console-producer.sh \
  --topic test \
  --bootstrap-server localhost:9092

kafka-console-consumer.sh \
  --topic test \
  --from-beginning \
  --bootstrap-server localhost:9092

八、Debian 系统层面检查

1. Java 环境

java -version

Kafka 推荐：

Java 11 或 Java 17（视 Kafka 版本）

2. 文件描述符限制

ulimit -n

建议：

ulimit -n 100000

3. 磁盘空间

df -h

九、快速自检清单（总结）

✅ Kafka 进程是否运行
✅ server.properties 是否正确
✅ 端口 9092 是否监听
✅ 日志是否报错
✅ ZooKeeper / KRaft 是否正常
✅ 是否能创建和读写 Topic

如果你愿意，可以把以下信息贴出来，我可以帮你精确定位问题：

Kafka 版本
server.properties
server.log 报错内容
你是 本地 / 服务器 / Docker 部署

我也可以给你一份 生产环境推荐配置。