Kafka怎么配在Debian

下面给你一份在 Debian（11/12 都可以）上安装并配置 Apache Kafka的实用步骤，偏“能跑起来、可用”的方向，不堆太多无关理论。

一、前置条件

1. 系统更新

sudo apt update
sudo apt upgrade -y

2. 安装 Java（Kafka 需要 JDK）

Kafka 3.x 推荐 Java 11 或 17

sudo apt install -y openjdk-17-jdk

验证：

java -version

二、安装 Kafka

1. 下载 Kafka（以 3.7.0 为例）

cd /opt
sudo wget https://downloads.apache.org/kafka/3.7.0/kafka_2.13-3.7.0.tgz
sudo tar -xzf kafka_2.13-3.7.0.tgz
sudo mv kafka_2.13-3.7.0 kafka

三、基本配置（单节点）

1. Zookeeper 配置（Kafka 3.3+ 也可用 KRaft，但初学者先用 ZK）

编辑：

sudo nano /opt/kafka/config/zookeeper.properties

关键项（一般默认即可）：

dataDir=/opt/kafka/zookeeper-data
clientPort=2181

创建目录：

sudo mkdir -p /opt/kafka/zookeeper-data

2. Kafka Server 配置

sudo nano /opt/kafka/config/server.properties

重点改这几项：

broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://<你的IP或localhost>:9092
log.dirs=/opt/kafka/kafka-logs
zookeeper.connect=localhost:2181

创建日志目录：

sudo mkdir -p /opt/kafka/kafka-logs

四、启动 Kafka（测试用）

1. 启动 Zookeeper

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

2. 启动 Kafka

新开一个终端：

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

能看到 started (kafka.server.KafkaServer) 就成功了。

五、快速验证

创建 Topic

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

生产消息

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

消费消息（另开终端）

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

六、做成 systemd 服务（推荐）

1. Zookeeper

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

[Unit]
Description=Zookeeper
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-abnormal

[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-abnormal

[Install]
WantedBy=multi-user.target

3. 启动

sudo systemctl daemon-reload
sudo systemctl enable --now zookeeper
sudo systemctl enable --now kafka

七、常见问题

端口被占用：检查 2181 / 9092
不能远程连：改 advertised.listeners
生产环境：不要用单副本，至少 3 broker + 3 ZK

如果你愿意，我可以接着给你：

✅ KRaft 模式（无 Zookeeper）
✅ 多 broker 集群配置
✅ Docker / Debian 生产部署方案

你现在是 学习用 还是 生产环境？