在 Debian 上启动 Kafka,通常步骤如下(以官方二进制包为例,不是 apt 安装,因为 Debian 官方源一般没有 Kafka)。
Kafka 需要 JVM(推荐 Java 8 / 11 / 17)
sudo apt update
sudo apt install -y openjdk-17-jdk
java -version
cd /opt
sudo wget https://downloads.apache.org/kafka/3.7.0/kafka_2.13-3.7.0.tgz
sudo tar -xzf kafka_2.13-3.7.0.tgz
sudo mv kafka_2.13-3.7.0 kafka
⚠️ Kafka 3.x 仍可用 Zookeeper(新版本可用 KRaft,但新手建议先 Zookeeper)
cd /opt/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties
这是前台运行,另开一个终端继续
cd /opt/kafka
bin/kafka-server-start.sh config/server.properties
看到类似日志说明启动成功:
[KafkaServer id=0] started
nohup bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeper.log 2>&1 &
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
/etc/systemd/system/zookeeper.service
[Unit]
Description=Zookeeper
After=network.target
[Service]
Type=simple
ExecStart=/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties
User=root
Restart=on-failure
[Install]
WantedBy=multi-user.target
/etc/systemd/system/kafka.service
[Unit]
Description=Kafka
After=zookeeper.service
[Service]
Type=simple
ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
User=root
Restart=on-failure
[Install]
WantedBy=multi-user.target
sudo systemctl daemon-reload
sudo systemctl start zookeeper
sudo systemctl start kafka
sudo systemctl enable zookeeper kafka
如果你是用 Docker / KRaft 模式 / apt 安装,告诉我,我可以给你对应方式。