温馨提示×

Kafka配置Debian步骤是啥

小樊
42
2026-08-22 06:25:28
栏目: 智能运维

下面给你一份在 Debian 系统上安装和配置 Apache Kafka 的完整步骤(单机版),适合新手或测试环境。


一、环境准备

1. 更新系统

sudo apt update
sudo apt upgrade -y

2. 安装 Java(Kafka 依赖 JVM)

Kafka 需要 Java 8 或以上版本。

sudo apt install openjdk-17-jdk -y

验证:

java -version

二、下载并安装 Kafka

1. 创建安装目录

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

2. 下载 Kafka(以 3.6.1 为例)

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

可在 https://kafka.apache.org/downloads 查看最新版本

3. 解压

tar -xvzf kafka_2.13-3.6.1.tgz
mv kafka_2.13-3.6.1/* .
rm -rf kafka_2.13-3.6.1 kafka_2.13-3.6.1.tgz

三、配置 Kafka

1. Kafka 目录结构说明

/opt/kafka
 ├── config     # 配置文件
 ├── bin        # 启动脚本
 ├── logs

四、启动 Kafka(需要先启动 Zookeeper)

Kafka 3.x 仍可用 Zookeeper,也可使用 KRaft(无 Zookeeper),这里先用 Zookeeper。

1. 配置 Zookeeper

编辑:

nano config/zookeeper.properties

默认即可:

dataDir=/tmp/zookeeper
clientPort=2181

2. 启动 Zookeeper

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

后台运行(推荐):

nano start-zookeeper.sh
#!/bin/bash
/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties &
chmod +x start-zookeeper.sh
./start-zookeeper.sh

3. 配置 Kafka Server

编辑:

nano config/server.properties

常见配置项(可保持默认):

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

如需远程访问:

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

4. 启动 Kafka

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

后台运行:

nano start-kafka.sh
#!/bin/bash
/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties &
chmod +x start-kafka.sh
./start-kafka.sh

五、验证 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

4. 消费消息

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

六、设置开机自启(systemd,推荐)

如果你需要,我可以帮你写 Kafka + Zookeeper 的 systemd 服务文件,这样服务器重启后自动启动。


七、常见问题

1. Kafka 启动失败

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

2. 内存不足

编辑:

nano bin/kafka-server-start.sh

调整:

export KAFKA_HEAP_OPTS="-Xmx512M -Xms256M"

八、KRaft 模式(可选,无 Zookeeper)

如果你想要 Kafka 3.x 无 Zookeeper 配置,我也可以单独给你一份步骤。


如果你告诉我:

  • ✅ Debian 版本(10 / 11 / 12)
  • ✅ 是否生产环境
  • ✅ 是否需要集群

我可以给你更精确的配置方案

0