怎样在Debian装Kafka配置

下面给你一份在 Debian（如 Debian 11/12）上安装并配置 Apache Kafka的实用步骤，包含 Zookeeper 模式（传统），以及常见配置说明。

一、环境准备

1. 更新系统

sudo apt update
sudo apt upgrade -y

2. 安装 Java（Kafka 依赖 JVM）

Kafka 3.x 需要 Java 8 或以上：

sudo apt install -y default-jdk
java -version

二、下载并安装 Kafka

1. 创建用户（推荐）

sudo useradd -m -s /bin/bash kafka
sudo su - kafka

2. 下载 Kafka

以 Kafka 3.6.1 为例（可换版本）：

cd ~
wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz
tar -xzf kafka_2.13-3.6.1.tgz
mv kafka_2.13-3.6.1 kafka

三、配置 Zookeeper（传统模式）

1. 配置 Zookeeper

编辑：

vi ~/kafka/config/zookeeper.properties

常用配置：

dataDir=/home/kafka/zookeeper
clientPort=2181
maxClientCnxns=0

创建数据目录：

mkdir -p ~/zookeeper

四、配置 Kafka

1. 编辑 server.properties

vi ~/kafka/config/server.properties

核心配置（单机示例）：

broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://<服务器IP>:9092
log.dirs=/home/kafka/kafka-logs
num.partitions=1
default.replication.factor=1
zookeeper.connect=localhost:2181

创建日志目录：

mkdir -p ~/kafka-logs

五、启动 Kafka 和 Zookeeper

1. 启动 Zookeeper

~/kafka/bin/zookeeper-server-start.sh -daemon ~/kafka/config/zookeeper.properties

2. 启动 Kafka

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

3. 检查

jps
# 应看到 QuorumPeerMain 和 Kafka

六、测试 Kafka

1. 创建 Topic

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

2. 发送消息

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

3. 消费消息

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

七（可选）、用 systemd 管理

示例 /etc/systemd/system/kafka.service：

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

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

[Install]
WantedBy=multi-user.target

八、KRaft 模式（无 Zookeeper，Kafka 3.x+）

如果你想要 新架构（推荐），我也可以给你：

单节点 KRaft
多节点集群
Debian + Docker 方式

如果你愿意，可以告诉我：

✅ 单节点还是集群？
✅ 是否用 Docker？
✅ Kafka 版本要求？

我可以直接给你定制配置。