在 Linux 上启动 Kafka,通常需要先启动 Zookeeper(或 KRaft),再启动 Kafka Broker。下面按最常见的两种模式给你说明(以 Kafka 3.x 为例)。
tar -zxvf kafka_2.13-3.6.0.tgz
cd kafka_2.13-3.6.0
bin/zookeeper-server-start.sh config/zookeeper.properties
默认端口:
2181
如果想后台运行:
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 # Kafka
Kafka 2.8+ 支持,3.x 后逐步成为主流
bin/kafka-storage.sh random-uuid
例如得到:
xtz1234567890
bin/kafka-storage.sh format \
-t xtz1234567890 \
-c config/kraft/server.properties
bin/kafka-server-start.sh config/kraft/server.properties
后台运行:
nohup bin/kafka-server-start.sh config/kraft/server.properties > kafka.log 2>&1 &
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
netstat -tunlp | grep 9092
java -version
检查:
server.properties 中 log.dirs# 1. 启动 Zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
# 2. 启动 Kafka
bin/kafka-server-start.sh config/server.properties
bin/kafka-storage.sh format -t <UUID> -c config/kraft/server.properties
bin/kafka-server-start.sh config/kraft/server.properties
如果你告诉我:
我可以给你一份更贴合你场景的启动方案 ✅