centos怎样安装kafka

下面以 CentOS 7/8 为例，介绍 Kafka 单机安装（含 Zookeeper） 的常见步骤。Kafka 依赖 Java，先确认环境。

一、环境准备

1. 安装 Java

Kafka 需要 JDK 8 或以上（推荐 JDK 8/11）

java -version

如果没有 Java：

yum install -y java-1.8.0-openjdk

验证：

java -version

二、下载并安装 Kafka

1. 创建目录

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

2. 下载 Kafka

以 Kafka 3.6.1 为例（可到官网替换版本）：

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（单机）

1. 配置 Zookeeper

Kafka 自带 Zookeeper

编辑配置：

vi config/zookeeper.properties

一般只需确认：

dataDir=/tmp/zookeeper
clientPort=2181

2. 配置 Kafka

vi config/server.properties

重点配置：

broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://localhost:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181

四、启动 Kafka

1. 启动 Zookeeper

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

2. 启动 Kafka

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

3. 查看进程

jps

应有：

QuorumPeerMain（Zookeeper）
Kafka

五、测试 Kafka

1. 创建 Topic

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

2. 查看 Topic

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

3. 发送消息

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

4. 消费消息（新终端）

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

六、防火墙（可选）

如果远程访问：

firewall-cmd --add-port=9092/tcp --permanent
firewall-cmd --add-port=2181/tcp --permanent
firewall-cmd --reload

七、常见问题

无法绑定端口：检查 listeners 和防火墙
Kafka 起不来：看 kafka.log，通常是 Zookeeper 未启动
新版本 Kafka（3.x）：可不使用 Zookeeper（KRaft 模式）

如果你需要：

✅ Kafka 集群部署
✅ KRaft 模式（无 Zookeeper）
✅ systemd 服务化
✅ CentOS Stream / Rocky / Alma

告诉我你的版本和使用场景即可。