温馨提示×

linux kafka怎样启动

小樊
38
2026-09-17 12:04:47
栏目: 智能运维

在 Linux 上启动 Kafka,通常按以下步骤进行(以 Kafka 自带 Zookeeper 的方式为例,适用于学习/测试环境):


一、前提条件

  1. 已安装 JDK 8+
    java -version
    
  2. 已下载并解压 Kafka
    tar -xzf kafka_2.13-3.x.x.tgz
    cd kafka_2.13-3.x.x
    

二、启动 Zookeeper(Kafka 依赖)

Kafka 老版本依赖 Zookeeper:

# 后台启动
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

或前台启动(方便看日志):

bin/zookeeper-server-start.sh config/zookeeper.properties

三、启动 Kafka

# 后台启动
bin/kafka-server-start.sh -daemon config/server.properties

或前台启动:

bin/kafka-server-start.sh config/server.properties

四、验证 Kafka 是否启动成功

jps

应看到:

QuorumPeerMain   # Zookeeper
Kafka

或查看日志:

tail -f logs/server.log

五、简单测试

# 创建 topic
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 --bootstrap-server localhost:9092 --from-beginning

六、Kafka 3.x(KRaft 模式,无 Zookeeper)

如果你使用的是 Kafka 3.x 且不想用 Zookeeper

# 生成集群 ID
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 -daemon config/kraft/server.properties

七、停止 Kafka

bin/kafka-server-stop.sh
bin/zookeeper-server-stop.sh

如果你能告诉我:

  • Kafka 版本
  • 是否是生产环境
  • 是否使用 Docker

我可以给你更精确的启动方式。

0