ubuntu如何启动kafka

ubuntu

小樊

2026-08-17 18:33:17

栏目: 智能运维

在 Ubuntu 上启动 Apache Kafka，一般流程如下（以 Kafka 3.x + 自带 Zookeeper 为例，也是最常见的方式）。

一、前置条件

已安装 Java

java -version

如果没有安装：

sudo apt update
sudo apt install openjdk-11-jdk

已下载 Kafka 例如：

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

二、启动 Zookeeper（Kafka 依赖）

Kafka 自带 Zookeeper，先启动它：

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

✅ 看到类似 binding to port 2181 表示成功
✅ 不要关闭这个终端

三、启动 Kafka Broker

新开一个终端，进入 Kafka 目录：

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

✅ 看到 started (kafka.server.KafkaServer) 表示启动成功

四、验证 Kafka 是否启动成功

1️⃣ 查看进程

jps

应看到：

QuorumPeerMain   # Zookeeper
Kafka            # Kafka

2️⃣ 创建测试 Topic

bin/kafka-topics.sh --create \
--topic test \
--bootstrap-server localhost:9092 \
--partitions 1 \
--replication-factor 1

3️⃣ 查看 Topic

bin/kafka-topics.sh --list --bootstrap-server localhost:9092

五、停止 Kafka（关闭顺序很重要）

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

六、常见问题

❌ 端口被占用

netstat -tunlp | grep 9092

或

lsof -i:9092

七、Kafka 3.x（无 Zookeeper，KRaft 模式）

如果你用的是 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 config/kraft/server.properties

八、后台运行（生产环境推荐）

nohup bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeper.log 2>&1 &
nohup bin/kafka-server-start.sh config/server.properties > kafka.log 2>&1 &

如果你愿意，可以告诉我：

✅ Kafka 版本
✅ 是否用 Zookeeper
✅ 是本地测试还是服务器部署

我可以给你 更精确的启动方案 或 systemd 服务配置。