如何在Debian配置Kafka

在 Debian 上配置 Apache Kafka，一般流程包括：安装依赖 → 安装 Kafka → 配置 Kafka → 启动服务 → 验证。下面给你一个从零开始的完整示例（单机模式），适用于 Debian 10/11/12。

一、准备工作

1. 更新系统

sudo apt update && sudo apt upgrade -y

2. 安装 Java（Kafka 依赖 JVM）

Kafka 需要 Java 8 或以上版本，推荐 Java 17（或 11）。

sudo apt install openjdk-17-jdk -y

验证：

java -version

二、下载并安装 Kafka

1. 创建安装目录

sudo mkdir -p /opt/kafka
cd /opt/kafka

2. 下载 Kafka（以 3.6.1 为例）

wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz

2.13 是 Scala 版本，对 Kafka 使用无影响

3. 解压

tar -xzf kafka_2.13-3.6.1.tgz
mv kafka_2.13-3.6.1/* .
rm -rf kafka_2.13-3.6.1 kafka_2.13-3.6.1.tgz

三、配置 Kafka（单机）

1. Zookeeper 配置（Kafka 3.x 仍可用）

编辑：

nano config/zookeeper.properties

默认即可，常见配置：

dataDir=/tmp/zookeeper
clientPort=2181

2. Kafka Broker 配置

编辑：

nano config/server.properties

关键配置（单机示例）：

broker.id=0
listeners=PLAINTEXT://localhost:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181

如果是服务器，建议：

listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://<服务器IP>:9092

四、启动 Kafka

1. 启动 Zookeeper

bin/zookeeper-server-start.sh config/zookeeper.properties

建议后台运行：

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

2. 启动 Kafka Broker

bin/kafka-server-start.sh config/server.properties

后台运行：

bin/kafka-server-start.sh -daemon config/server.properties

五、验证 Kafka 是否运行

1. 查看进程

jps

应看到：

QuorumPeerMain
Kafka

2. 创建测试 Topic

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

查看 Topic：

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

3. 发送 & 消费消息

生产者：

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

消费者（新终端）：

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

六、配置为 systemd 服务（推荐）

1. Zookeeper service

sudo nano /etc/systemd/system/zookeeper.service

[Unit]
Description=Zookeeper
After=network.target

[Service]
Type=simple
User=root
ExecStart=/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties
ExecStop=/opt/kafka/bin/zookeeper-server-stop.sh
Restart=on-failure

[Install]
WantedBy=multi-user.target

2. Kafka service

sudo nano /etc/systemd/system/kafka.service

[Unit]
Description=Apache Kafka
After=zookeeper.service

[Service]
Type=simple
User=root
ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
ExecStop=/opt/kafka/bin/kafka-server-stop.sh
Restart=on-failure

[Install]
WantedBy=multi-user.target

3. 启动并设置开机自启

sudo systemctl daemon-reload
sudo systemctl enable zookeeper
sudo systemctl enable kafka
sudo systemctl start zookeeper
sudo systemctl start kafka

七、常见问题

1. Kafka 启动慢

• 检查 Java 版本
• 确保 /tmp 可写

2. 端口被占用

ss -lntp | grep 9092

3. 防火墙（如开启）

sudo ufw allow 9092

八、下一步建议

• 配置 KRaft 模式（无 Zookeeper）
• 配置 多 broker 集群
• 配置 安全认证（SASL / SSL）
• 与 Debian + Docker / Kubernetes 集成

如果你告诉我：

• ✅ Debian 版本
• ✅ 单节点还是集群
• ✅ 是否生产环境

我可以给你更精确的配置方案。