温馨提示×

Linux Kafka如何安装

小樊
40
2026-07-06 10:44:28
栏目: 智能运维

下面以 Linux(以 CentOS / Ubuntu 为例) 说明 Kafka 的安装与基本启动步骤。Kafka 依赖 Java,我会从环境准备开始。


一、环境准备

1. 安装 Java(Kafka 需要 JDK 8+)

CentOS

sudo yum install -y java-1.8.0-openjdk

Ubuntu

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

验证:

java -version

二、下载并安装 Kafka

1. 创建安装目录

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

2. 下载 Kafka(推荐 3.x 稳定版)

Kafka 3.6.1 为例(Scala 2.13):

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

解压:

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

目录结构说明:

  • bin/:启动脚本
  • config/:配置文件
  • logs/:日志目录

三、启动 Kafka(单机模式)

Kafka 依赖 Zookeeper(新版本也可使用 KRaft,下面先讲 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 &

四、验证 Kafka 是否成功

1. 查看进程

jps

应看到:

QuorumPeerMain   # Zookeeper
Kafka

2. 创建 Topic

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

3. 查看 Topic

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

4. 发送消息(生产者)

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

5. 消费消息(消费者)

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

五、常见问题

1. Kafka 启动失败

  • 检查 Java 是否安装
  • 检查端口 9092 是否被占用
netstat -tunlp | grep 9092

2. 修改 Kafka 监听地址

编辑:

vim config/server.properties

修改:

listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://<服务器IP>:9092

六、KRaft 模式(无 Zookeeper,推荐新版本)

如果你使用的是 Kafka 3.x+,可以不用 Zookeeper:

# 生成 UUID
bin/kafka-storage.sh random-uuid

# 格式化日志目录
bin/kafka-storage.sh format -t <UUID> -c config/kraft/server.properties

# 启动
bin/kafka-server-start.sh config/kraft/server.properties

七、总结

✅ 安装步骤:

  1. 安装 Java
  2. 下载并解压 Kafka
  3. 启动 Zookeeper
  4. 启动 Kafka
  5. 创建 Topic 并测试

如果你需要:

  • 集群部署
  • 生产环境配置
  • Docker / Kubernetes 安装
  • KRaft 模式详细配置

可以告诉我你的使用场景,我可以给你更完整的方案。

0