温馨提示×

debian下怎么配kafka呀

小樊
43
2026-09-06 23:49:14
栏目: 智能运维

在 Debian 下配置 Kafka,通常分为 安装 JDK → 下载 Kafka → 配置 → 启动 → 测试 几个步骤。下面给你一个单机版(开发/测试)的清晰流程,如果你要集群版我可以再补。


一、环境准备

1. 安装 JDK(Kafka 依赖 Java)

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

(Kafka 3.x 推荐 JDK 11 / 17)

验证:

java -version

二、下载并安装 Kafka

以 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(单节点)

1. Zookeeper(Kafka 自带)

Kafka 3.x 仍可用 Zookeeper(KRaft 模式可后讲)

编辑:

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

默认一般够用:

dataDir=/tmp/zookeeper
clientPort=2181

2. Kafka Server 配置

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

关键配置(单机):

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

四、启动 Kafka

1. 启动 Zookeeper

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

2. 启动 Kafka

新开一个终端:

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

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


五、测试 Kafka 是否可用

1. 创建 Topic

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

2. 生产消息

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

输入任意内容,回车

3. 消费消息

新终端:

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

能收到消息 ✅


六、常见问题

❌ 端口被占用

sudo netstat -tunlp | grep 9092

❌ 开机自启(systemd)

需要我给你写 kafka.service 和 zookeeper.service 文件也可以。


七、可选:KRaft 模式(无 Zookeeper)

Kafka 3.x 支持,但配置稍复杂,适合生产。


如果你告诉我:

  • ✅ 是 开发 / 生产
  • ✅ 是否 集群
  • ✅ Debian 版本(11 / 12)

我可以直接给你 定制版配置 + systemd 自启脚本。

0 踩