如何安装Linux Kafka

下面以 Linux（Ubuntu / CentOS 等通用发行版） 为例，详细说明 Apache Kafka 的安装与基本启动流程。示例基于 Kafka 3.x + Java 17（或 Java 8/11）。

一、前置条件

1. 安装 Java

Kafka 依赖 Java 环境。

# Ubuntu / Debian
sudo apt update
sudo apt install openjdk-17-jdk -y

# CentOS / Rocky / Alma
sudo yum install java-17-openjdk -y

验证：

java -version

二、下载并安装 Kafka

示例版本：kafka_2.13-3.6.1
（2.13 是 Scala 版本，不影响使用）

1. 进入安装目录

cd /opt

2. 下载 Kafka

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

3. 解压

tar -zxvf kafka_2.13-3.6.1.tgz
mv kafka_2.13-3.6.1 kafka
cd kafka

三、启动 Zookeeper（Kafka 依赖）

⚠️ Kafka 新版本已支持 KRaft 模式（无 Zookeeper），但初学者建议先用 Zookeeper。

1. 启动 Zookeeper

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

✅ 看到 binding to port 2181 表示成功。

四、启动 Kafka

新开一个终端：

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

2. 查看 Topic

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

六、测试生产与消费

1. 启动生产者

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

输入消息：

hello kafka

2. 启动消费者（新终端）

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

✅ 能收到消息说明 Kafka 安装成功。

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

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

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

八、常见问题

1. Kafka 启动失败

检查 Java 是否安装
端口 9092 / 2181 是否被占用

netstat -tunlp | grep 9092

2. 内存不足

修改：

bin/kafka-server-start.sh

调整：

export KAFKA_HEAP_OPTS="-Xmx512M -Xms256M"

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

如果你需要 Kafka 3.3+ 去掉 Zookeeper 的部署方式，我可以提供完整步骤。

十、总结

✅ 基本流程：

安装 Java
下载 Kafka
启动 Zookeeper
启动 Kafka
创建 Topic 并测试

如果你告诉我：

✅ Linux 发行版
✅ 是否用于生产环境
✅ 是否使用 Docker / 集群

我可以给你 定制版安装方案。