在 Linux 上启动 Kafka,通常步骤如下(以官方二进制包为例,最常见场景):
Kafka 依赖 Zookeeper(老版本)或内置 KRaft(新版本 3.x+)
java -version
没有就装:
yum install java-1.8.0-openjdk -y # CentOS
# 或
apt install openjdk-11-jdk -y # Ubuntu
wget https://archive.apache.org/dist/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
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 &
jps
应看到:
QuorumPeerMain # Zookeeper
Kafka
或看日志:
tail -f kafka.log
KAFKA_CLUSTER_ID=$(bin/kafka-storage.sh random-uuid)
bin/kafka-storage.sh format -t $KAFKA_CLUSTER_ID -c config/kraft/server.properties
bin/kafka-server-start.sh config/kraft/server.properties
bin/kafka-server-stop.sh
bin/zookeeper-server-stop.sh
firewall-cmd --add-port=9092/tcp --permanent
firewall-cmd --reload
如果你告诉我:
我可以直接给你精确命令。