在 Debian 系统中启动 Apache Kafka,通常步骤如下(以官方二进制包为例,不是 apt 安装):
java -version
推荐 Java 8 或 Java 11
wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz
tar -xzf kafka_2.13-3.6.1.tgz
cd kafka_2.13-3.6.1
Kafka 3.0+ 可用 KRaft 模式(无需 Zookeeper),但默认仍是 Zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
后台运行:
nohup bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeper.log 2>&1 &
新开终端或后台启动:
bin/kafka-server-start.sh config/server.properties
后台运行:
nohup bin/kafka-server-start.sh config/server.properties > kafka.log 2>&1 &
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
如果能正常执行,说明启动成功。
/etc/systemd/system/kafka.service
[Unit]
Description=Apache Kafka
After=network.target zookeeper.service
[Service]
Type=simple
User=kafka
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
systemctl daemon-reload
systemctl start kafka
systemctl enable kafka
config/server.properties 或 JVM 参数listeners 和 advertised.listeners如果你是用 apt 安装 或 Docker 启动 Kafka,也可以告诉我,我可以给你对应方式。