下面给你一个在 Ubuntu 上从零开始配置并启动 Kafka的简明实战流程(以 Kafka 3.x + Kafka 自带的 Zookeeper 为例,最常见、最适合入门)。
sudo apt update
sudo apt install openjdk-11-jdk -y
验证:
java -version
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
Kafka 自带 Zookeeper,先启动它:
cd /opt/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties
✅ 看到 binding to port 0.0.0.0/0.0.0.0:2181 表示成功
生产环境建议用单独终端或后台运行
新开一个终端:
cd /opt/kafka
bin/kafka-server-start.sh config/server.properties
✅ 出现 started (kafka.server.KafkaServer) 表示启动成功
编辑:
nano config/server.properties
常见修改:
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://你的IP:9092
改完重启 Kafka。
bin/kafka-topics.sh --create \
--topic test \
--bootstrap-server localhost:9092 \
--partitions 1 \
--replication-factor 1
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
bin/kafka-console-producer.sh \
--topic test \
--bootstrap-server localhost:9092
输入:
hello kafka
bin/kafka-console-consumer.sh \
--topic test \
--from-beginning \
--bootstrap-server localhost:9092
✅ 能看到 hello kafka 说明 Kafka 正常工作
nohup bin/zookeeper-server-start.sh config/zookeeper.properties > zk.log 2>&1 &
nohup bin/kafka-server-start.sh config/server.properties > kafka.log 2>&1 &
server.properties 配置错误advertised.listenerssudo ufw allow 9092
如果你告诉我:
✅ Ubuntu 版本
✅ 单机能跑还是集群
✅ Kafka 用途(日志 / 消息队列 / 流处理)
我可以给你更精确的配置方案。