在 Debian 上运行 Kafka,通常搭配 Zookeeper(或新版本的 KRaft 模式)。下面我给你一份从零开始、可落地的配置教程,适用于 Debian 11 / 12。
Kafka 需要 JDK 8 或以上(推荐 JDK 17)
sudo apt update
sudo apt install -y openjdk-17-jdk
验证:
java -version
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 3.x 仍支持 Zookeeper,简单稳定
vi config/zookeeper.properties
常见配置:
dataDir=/opt/kafka/zookeeper-data
clientPort=2181
maxClientCnxns=0
创建数据目录:
mkdir -p /opt/kafka/zookeeper-data
vi config/server.properties
核心配置(单机示例):
broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://<你的服务器IP>:9092
log.dirs=/opt/kafka/kafka-logs
num.partitions=3
default.replication.factor=1
zookeeper.connect=localhost:2181
创建日志目录:
mkdir -p /opt/kafka/kafka-logs
bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties
看到:
[KafkaServer id=0] started
说明成功 ✅
bin/kafka-topics.sh --create \
--topic test \
--bootstrap-server localhost:9092 \
--partitions 1 --replication-factor 1
bin/kafka-console-producer.sh \
--topic test --bootstrap-server localhost:9092
bin/kafka-console-consumer.sh \
--topic test --from-beginning --bootstrap-server localhost:9092
sudo vi /etc/systemd/system/zookeeper.service
[Unit]
Description=Apache 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-abnormal
[Install]
WantedBy=multi-user.target
sudo vi /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-abnormal
[Install]
WantedBy=multi-user.target
sudo systemctl daemon-reload
sudo systemctl enable zookeeper kafka
sudo systemctl start zookeeper kafka
sudo ufw allow 9092
sudo ufw allow 2181
如果你用的是 Kafka 3.3+,我也可以给你:
✅ Kafka 起不来?
advertised.listenerslogs/server.log✅ 远程连不上?
advertised.listeners 必须是公网/内网 IP如果你愿意,可以告诉我:
我可以直接给你 一份定制配置。