在 Debian 上启动 Kafka 服务,通常有两种方式:直接命令行启动(适合测试)和systemd 服务方式(适合生产/长期使用)。下面分别说明。
Kafka 依赖 Zookeeper(Kafka 2.x/3.x 旧版本)或KRaft 模式(Kafka 3.x+ 新版本)。
java -version
若无 Java:
sudo apt update
sudo apt install default-jdk -y
假设 Kafka 解压在:
/opt/kafka
/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties
另开一个终端:
/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
若想后台运行:
nohup /opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties > /var/log/kafka.log 2>&1 &
sudo nano /etc/systemd/system/zookeeper.service
内容:
[Unit]
Description=Apache Zookeeper
After=network.target
[Service]
Type=simple
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 nano /etc/systemd/system/kafka.service
内容:
[Unit]
Description=Apache Kafka
After=zookeeper.service
[Service]
Type=simple
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 start zookeeper
sudo systemctl start kafka
sudo systemctl enable zookeeper
sudo systemctl enable kafka
/opt/kafka/bin/kafka-storage.sh random-uuid
/opt/kafka/bin/kafka-storage.sh format -t <CLUSTER_ID> -c /opt/kafka/config/kraft/server.properties
/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/kraft/server.properties
/opt/kafka/bin/kafka-topics.sh --list --bootstrap-server localhost:9092
如果你能告诉我:
我可以给你更精确的启动方案。