温馨提示×

怎样启动debian kafka

小樊
50
2026-09-25 04:43:39
栏目: 智能运维

在 Debian 上启动 Kafka,一般流程是:安装 JDK → 下载/安装 Kafka → 启动 Zookeeper(或 KRaft)→ 启动 Kafka。下面给你一份从零开始的常见做法(以 Kafka 3.x 为例,包含 Zookeeper 模式 和 KRaft 模式)。


一、前置条件

1. 更新系统

sudo apt update
sudo apt upgrade -y

2. 安装 Java(Kafka 需要 JDK 8+)

sudo apt install -y default-jdk
java -version

二、下载并解压 Kafka

cd /opt
sudo wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz
sudo tar -xzf kafka_2.13-3.6.1.tgz
sudo mv kafka_2.13-3.6.1 kafka

三、方式一:Zookeeper 模式(传统方式)

1. 启动 Zookeeper

cd /opt/kafka
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 &

3. 验证

bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092
bin/kafka-topics.sh --list --bootstrap-server localhost:9092

四、方式二:KRaft 模式(Kafka 3.x 推荐,无 Zookeeper)

1. 生成集群 ID

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

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

后台运行:

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

五、常见问题

1. 端口被占用

  • Kafka 默认:9092
  • Zookeeper 默认:2181

2. 开机自启(systemd 示例)

可帮你写 kafka.service 文件(需要的话告诉我)。

3. Debian 防火墙

sudo ufw allow 9092

如果你告诉我:

  • 用的是 Debian 几
  • Kafka 版本
  • 是否用 Docker / 单机 / 集群

我可以给你更精确的启动方式。

0 踩