怎么在Ubuntu搭建Kafka

以下是在 Ubuntu 上搭建 Apache Kafka 的详细步骤，适用于 单机/本地开发环境。如果你需要 集群部署 或 生产环境配置，可以再告诉我。

一、环境准备

1. 系统要求

Ubuntu 20.04 / 22.04（推荐）
Java 8 或以上（Kafka 依赖 JVM）

2. 安装 Java

Kafka 需要 Java 运行环境：

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

验证：

java -version

二、下载并安装 Kafka

1. 下载 Kafka

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

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

2.13 是 Scala 版本，不影响使用

2. 解压

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

三、启动 Kafka（先启动 Zookeeper）

⚠️ Kafka 3.x 仍然默认依赖 Zookeeper（KRaft 模式可选）

1. 启动 Zookeeper

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

✅ 看到 binding to port 2181 表示成功

2. 启动 Kafka Broker

新开一个终端：

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

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

四、测试 Kafka 是否正常运行

1. 创建 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

2. 发送消息（生产者）

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

输入内容：

hello kafka

3. 消费消息（消费者）

新开终端：

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

✅ 能看到 hello kafka 即成功

五、后台运行（生产建议）

使用 nohup 或 systemd

示例（简单方式）：

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

七、常见问题

1. Kafka 启动失败

检查：

java -version
netstat -tunlp | grep 9092

2. 端口被占用

9092：Kafka
2181：Zookeeper

八、进阶（可选）

✅ KRaft 模式（无 Zookeeper）
✅ Kafka 集群
✅ Kafka + Spring Boot
✅ Kafka 安全（SASL / SSL）

如果你需要 生产环境部署方案 或 Docker / Kubernetes 部署，告诉我你的使用场景即可。