Ubuntu怎么安装Kafka呢

在 Ubuntu 上安装 Apache Kafka，最常用、最稳妥的方式是：下载官方 Kafka 二进制包 + 使用内置 Zookeeper（或 KRaft 模式）。下面我给你一个 从零开始的完整安装教程（适合新手）。

一、安装前准备

1️⃣ 安装 Java（Kafka 依赖 Java）

Kafka 需要 Java 8 或以上，推荐 Java 11 或 17。

sudo apt update
sudo apt install openjdk-17-jdk -y

验证：

java -version

二、下载并安装 Kafka

2️⃣ 下载 Kafka

去官网复制最新版本地址（示例为 3.6.1）：

cd /opt
sudo wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz

2.13 是 Scala 版本，不影响使用

3️⃣ 解压

sudo tar -xzf kafka_2.13-3.6.1.tgz
sudo mv kafka_2.13-3.6.1 kafka

三、启动 Kafka（两种方式）

✅ 方案一：使用 Zookeeper（传统方式，推荐新手）

4️⃣ 启动 Zookeeper

cd /opt/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties

默认端口：2181

5️⃣ 启动 Kafka

新开一个终端：

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

默认端口：9092

✅ 看到 started 说明成功

四、测试 Kafka 是否可用

6️⃣ 创建 Topic

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

查看 Topic：

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

7️⃣ 发送消息（生产者）

bin/kafka-console-producer.sh \
--topic test-topic \
--bootstrap-server localhost:9092

输入内容后回车，例如：

hello kafka

8️⃣ 消费消息（消费者）

新开终端：

bin/kafka-console-consumer.sh \
--topic test-topic \
--from-beginning \
--bootstrap-server localhost:9092

✅ 能看到刚才发送的消息，说明 Kafka 正常运行

五、后台运行（推荐）

9️⃣ 使用 nohup 后台启动

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

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

七、KRaft 模式（无 Zookeeper，进阶）

如果你用的是 Kafka 3.x+，可以使用 KRaft 模式（不需要 Zookeeper）：

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

⚠️ 新手建议先用 Zookeeper 模式

八、常见问题

❓ Kafka 启动失败

Java 没装好
端口 2181 / 9092 被占用
内存不足（可修改 server.properties）

❓ 防火墙问题

sudo ufw allow 9092

九、总结（最简流程）

sudo apt install openjdk-17-jdk
wget kafka
tar -xzf kafka
启动 zookeeper
启动 kafka
创建 topic
生产 / 消费消息

如果你愿意，我可以帮你：

✅ 写成 一键安装脚本
✅ 配置 systemd 服务
✅ 配置 集群模式
✅ 用 Docker 安装 Kafka

你打算 学习 / 开发 / 生产环境 用？