温馨提示×

kafka在debian怎么设置

小樊
42
2026-09-03 18:36:13
栏目: 智能运维

下面按在 Debian 上安装并配置 Kafka(单机示例)来讲,适合入门和测试环境。如果你要的是集群 / 生产配置,我也可以再补。


一、环境准备

1. 安装 Java(Kafka 需要 JVM)

Kafka 3.x 推荐 Java 8 / 11 / 17

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

验证:

java -version

二、下载并安装 Kafka

2. 下载 Kafka(以 3.7 为例)

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

3. 配置 Zookeeper(Kafka 自带)

编辑:

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

常见修改:

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

创建目录:

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

4. 配置 Kafka

编辑:

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

关键配置(单机):

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

创建日志目录:

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

四、启动 Kafka

5. 启动 Zookeeper

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

(后台运行加 & 或用 systemd)


6. 启动 Kafka

新开终端:

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

五、测试 Kafka

7. 创建 Topic

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

8. 发送消息

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

9. 消费消息

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

六、设为系统服务(推荐)

如果你想开机自启,我可以帮你写 systemd 的 zookeeper + kafka 服务文件


七、常见问题

  • Kafka 起不来:先看 logs/ 下日志
  • 端口占用:检查 2181 / 9092
  • 云服务器:改 advertised.listeners 为公网 IP

如果你告诉我:

  • Debian 版本
  • Kafka 用途(测试 / 生产 / 集群)
  • 是否用 Docker

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

0