下面以 Debian 11/12 为例,给你一个 从零部署 Kafka(单机版,生产可用基础) 的完整流程。如果你需要 集群版 或 Docker 部署,我也可以补充。
sudo apt update
sudo apt upgrade -y
Kafka 3.x 推荐 Java 17(也兼容 Java 11)
sudo apt install -y openjdk-17-jdk
验证:
java -version
官方已内置 Zookeeper(Kafka 3.3+ 也可用 KRaft,但新手建议先用 Zookeeper)
sudo mkdir -p /opt/kafka
cd /opt/kafka
wget https://downloads.apache.org/kafka/3.7.0/kafka_2.13-3.7.0.tgz
tar -xzf kafka_2.13-3.7.0.tgz
mv kafka_2.13-3.7.0/* .
rm -rf kafka_2.13-3.7.0 kafka_2.13-3.7.0.tgz
bin/zookeeper-server-start.sh config/zookeeper.properties
后台运行:
nohup bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeper.log 2>&1 &
vim config/server.properties
常见必要修改:
broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://你的服务器IP:9092
log.dirs=/opt/kafka/logs
num.partitions=3
创建日志目录:
mkdir -p /opt/kafka/logs
nohup bin/kafka-server-start.sh config/server.properties > kafka.log 2>&1 &
bin/kafka-topics.sh --create \
--topic test \
--bootstrap-server localhost:9092 \
--partitions 1 \
--replication-factor 1
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
bin/kafka-console-producer.sh \
--topic test \
--bootstrap-server localhost:9092
输入:
hello kafka
bin/kafka-console-consumer.sh \
--topic test \
--from-beginning \
--bootstrap-server localhost:9092
能看到消息即部署成功 ✅
sudo vim /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
sudo vim /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
sudo systemctl daemon-reload
sudo systemctl enable zookeeper
sudo systemctl enable kafka
sudo systemctl start zookeeper
sudo systemctl start kafka
sudo ufw allow 9092
sudo ufw allow 2181
log.dirs 是否存在kafka.logadvertised.listeners 必须写 真实 IP如果你告诉我:
✅ 是否集群
✅ 是否云服务器
✅ Debian 具体版本
我可以给你 更精准的部署方案。