debian下kafka怎样配置

下面以 Debian 11/12 为例，说明 Kafka 在 Debian 下的基本安装与配置。Kafka 依赖 Java 和 Zookeeper（或 KRaft 模式）。

一、环境准备

1. 安装 Java

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

sudo apt update
sudo apt install -y openjdk-17-jdk

验证：

java -version

二、安装 Kafka

方式一：官方二进制包（推荐）

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

三、Kafka 运行模式选择

✅ 模式 A：Zookeeper 模式（传统，稳定）

1. 启动 Zookeeper

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

2. 启动 Kafka

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

✅ 模式 B：KRaft 模式（Kafka 3.x 推荐，无 Zookeeper）

1. 生成 Cluster ID

KAFKA_CLUSTER_ID=$(bin/kafka-storage.sh random-uuid)

2. 格式化存储

bin/kafka-storage.sh format \
  -t $KAFKA_CLUSTER_ID \
  -c config/kraft/server.properties

3. 启动 Kafka

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

四、基础配置说明（server.properties）

常见关键配置：

# broker 唯一 ID
broker.id=0

# 监听地址
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://your-host-ip:9092

# 日志目录
log.dirs=/tmp/kafka-logs

# Zookeeper（Zookeeper 模式）
zookeeper.connect=localhost:2181

⚠️ 生产环境一定要改 log.dirs 到独立磁盘

五、Systemd 配置（推荐）

1. Kafka Service

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

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

[Service]
Type=simple
User=root
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

sudo systemctl daemon-reload
sudo systemctl enable kafka
sudo systemctl start kafka

六、基本测试

创建 Topic

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

发送消息

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

消费消息

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

七、常见问题

1. 外网无法连接

修改：

advertised.listeners=PLAINTEXT://公网IP:9092

2. 端口未开放

sudo ufw allow 9092

如果你需要：

• 集群部署
• SSL / SASL 安全配置
• Docker / Debian + Kafka 最佳实践

可以告诉我你的使用场景。