温馨提示×

Debian Kafka配置啥步骤

小樊
44
2026-10-03 21:48:05
栏目: 智能运维

下面给你一份在 Debian 上部署 Kafka(单机/伪集群)的常见配置步骤,以 Kafka 3.x + Java 17 为例,适合学习和测试环境。


一、环境准备

1. 更新系统

sudo apt update
sudo apt upgrade -y

2. 安装 Java

Kafka 依赖 JVM:

sudo apt install -y openjdk-17-jdk
java -version

二、安装 Kafka

1. 下载 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

三、配置 Zookeeper(Kafka 依赖)

Kafka 3.x 仍可用 Zookeeper(新版可用 KRaft,但 Zookeeper 更常见)

1. 配置 Zookeeper

编辑:

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

常用配置:

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

创建数据目录:

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

四、配置 Kafka

1. 编辑 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
num.partitions=1

创建日志目录:

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

五、启动 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

六、基础测试

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 \
--from-beginning \
--bootstrap-server localhost:9092

七、(可选)设为系统服务

可创建 systemd 服务,防止终端关闭 Kafka 停止运行(需要我可以给你完整 service 文件)。


八、常见问题

  • 端口占用:检查 2181 / 9092
  • 无法连接:检查 advertised.listeners
  • 内存不足:调整 KAFKA_HEAP_OPTS

如果你需要:

  • ✅ Debian + KRaft 模式(无 Zookeeper)
  • ✅ 集群部署
  • ✅ 生产环境参数优化
  • ✅ systemd 自动启动

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

0 踩