温馨提示×

Debian安装Kafka步骤是什么

小樊
49
2026-08-06 20:17:25
栏目: 智能运维

下面是在 Debian 系统上安装 Apache Kafka完整步骤示例(以 Kafka 3.x + Java 17 为例,适用于 Debian 11/12)。


一、准备环境

1. 更新系统

sudo apt update
sudo apt upgrade -y

2. 安装 Java(Kafka 依赖 JVM)

Kafka 3.x 建议使用 Java 17Java 11

sudo apt install openjdk-17-jdk -y

验证:

java -version

二、下载并安装 Kafka

1. 进入安装目录

cd /opt

2. 下载 Kafka

前往官网获取最新版本地址:
https://kafka.apache.org/downloads

示例(以 3.7.0 为例):

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

3. 解压

tar -xzf kafka_2.13-3.7.0.tgz
mv kafka_2.13-3.7.0 kafka

三、启动 Kafka(使用内置 Zookeeper)

Kafka 新版本已逐步移除 Zookeeper,但当前仍可用。

1. 启动 Zookeeper

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

可加 & 后台运行,或另开终端

2. 启动 Kafka Broker

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

四、测试 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

3. 发送消息(生产者)

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

输入内容后按 Ctrl+C 退出。

4. 消费消息(消费者)

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

五、配置为系统服务(可选)

1. 创建 Zookeeper 服务

sudo nano /etc/systemd/system/zookeeper.service

内容:

[Unit]
Description=Zookeeper Service
After=network.target

[Service]
Type=simple
ExecStart=/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties
ExecStop=/opt/kafka/bin/zookeeper-server-stop.sh
Restart=on-failure

[Install]
WantedBy=multi-user.target

2. 创建 Kafka 服务

sudo nano /etc/systemd/system/kafka.service

内容:

[Unit]
Description=Apache Kafka
After=zookeeper.service

[Service]
Type=simple
ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
ExecStop=/opt/kafka/bin/kafka-server-stop.sh
Restart=on-failure

[Install]
WantedBy=multi-user.target

3. 启动服务

sudo systemctl daemon-reload
sudo systemctl start zookeeper
sudo systemctl start kafka

设置开机自启:

sudo systemctl enable zookeeper
sudo systemctl enable kafka

六、常见问题

1. Kafka 无法启动

检查:

java -version
netstat -tulnp | grep 9092

2. 防火墙

sudo ufw allow 9092

七、Kafka 目录说明

/opt/kafka
├── bin        # 启动脚本
├── config     # 配置文件
├── logs       # 日志
└── libs       # 依赖库

如果你需要:

  • Kafka + KRaft(无 Zookeeper)
  • 集群部署
  • Debian + Docker 安装
  • 生产环境优化

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

0