温馨提示×

怎样在debian配kafka呢

小樊
42
2026-09-25 04:29:42
栏目: 智能运维

下面给你一份**在 Debian 上从零配置 Kafka(单机版)**的实用步骤,适合学习、测试或轻量生产使用。


一、环境准备

1. 系统要求

  • Debian 11 / 12
  • Java 8 或以上(推荐 Java 17)

2. 安装 Java

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

验证:

java -version

二、下载并安装 Kafka

Kafka 自带 Zookeeper(2.x/3.x 版本仍可用)。

1. 创建目录

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

2. 下载 Kafka

以 Kafka 3.6.1 为例(可换版本):

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/* .
rm -rf kafka_2.13-3.6.1 kafka_2.13-3.6.1.tgz

三、配置 Kafka

1. 配置 Zookeeper

vim config/zookeeper.properties

默认即可,常用配置:

dataDir=/tmp/zookeeper
clientPort=2181

2. 配置 Kafka

vim config/server.properties

关键配置(单机):

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

如果是远程访问,把 localhost 改成服务器 IP


四、启动 Kafka

1. 启动 Zookeeper

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

后台运行:

nohup bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeper.log 2>&1 &

2. 启动 Kafka

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

后台:

nohup bin/kafka-server-start.sh config/server.properties > kafka.log 2>&1 &

五、测试 Kafka

1. 创建 Topic

bin/kafka-topics.sh --create \
  --topic test \
  --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 \
  --bootstrap-server localhost:9092

4. 消费消息

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

六(可选)、用 systemd 管理 Kafka

1. Zookeeper service

sudo vim /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-failure

[Install]
WantedBy=multi-user.target

2. Kafka service

sudo vim /etc/systemd/system/kafka.service
[Unit]
Description=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 enable --now zookeeper
sudo systemctl enable --now kafka

七、常见问题

  • 端口占用:检查 2181 / 9092
  • 无法远程连接:检查 advertised.listeners
  • Kafka 3.x 可不用 Zookeeper(KRaft),如需可单独说

如果你想要:

  • ✅ KRaft 模式(无 Zookeeper)
  • ✅ 集群配置
  • ✅ Docker 方式
  • ✅ 安全认证(SASL/SSL)

告诉我你的使用场景,我可以直接给你对应配置。

0 踩