温馨提示×

linux怎么安装kafka

小樊
48
2026-09-14 10:59:22
栏目: 智能运维

下面给你一份 在 Linux 上安装 Kafka 的常用实践教程(以 Kafka 3.x + Kafka 自带 ZooKeeper 为例,适合学习和测试环境)。


一、环境准备

1. 系统要求

  • Linux(CentOS / Ubuntu / Rocky 等均可)
  • Java 8 或以上(推荐 Java 11)

2. 安装 Java

# CentOS / Rocky
yum install -y java-11-openjdk

# Ubuntu / Debian
apt update
apt install -y openjdk-11-jdk

# 验证
java -version

二、下载并安装 Kafka

1. 创建目录

mkdir -p /opt/kafka
cd /opt/kafka

2. 下载 Kafka

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

版本可自行替换

3. 解压

tar -xzf kafka_2.13-3.6.1.tgz
mv kafka_2.13-3.6.1/* .

三、启动 Kafka(自带 ZooKeeper)

1. 启动 ZooKeeper

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

后台运行:

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

2. 启动 Kafka

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

后台运行:

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

四、基本测试

1. 创建 Topic

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

2. 查看 Topic

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

3. 生产消息

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

4. 消费消息

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

五、常见问题

1. 端口被占用

  • Kafka 默认:9092
  • ZooKeeper 默认:2181

2. 外网无法连接

修改 config/server.properties

listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://你的IP:9092

3. 开机自启(简单示例)

# 使用 systemd(略,可帮你写完整 service 文件)

六、Kafka 3.x 新特性(可选)

  • 可使用 KRaft 模式(不依赖 ZooKeeper)
  • 生产环境推荐 Kafka + 外部 ZooKeeper 或 KRaft

如果你告诉我:

  • Linux 发行版(CentOS / Ubuntu)
  • 是否用于 生产环境
  • 是否使用 Docker / 集群

我可以给你 更合适的安装方案或 systemd 脚本

0