下面给你一份**在 Ubuntu 上安装并配置 Kafka(单机版)**的完整步骤,适合入门和本地测试。
示例基于 Ubuntu 20.04 / 22.04,Kafka 版本以 3.x 为例。
Kafka 依赖 Java(推荐 JDK 8 / 11 / 17)
sudo apt update
sudo apt install openjdk-11-jdk -y
验证:
java -version
cd /opt
sudo mkdir kafka
cd kafka
sudo wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz
如果你在国内慢,可换清华镜像:
wget https://mirrors.tuna.tsinghua.edu.cn/apache/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(3.x)可不用 Zookeeper,但新手建议先用 Zookeeper 模式
sudo nano config/zookeeper.properties
常用配置:
dataDir=/opt/kafka/zookeeper-data
clientPort=2181
bin/zookeeper-server-start.sh config/zookeeper.properties
✅ 看到 binding to port 0.0.0.0/0.0.0.0:2181 表示成功
sudo nano config/server.properties
常见修改:
broker.id=0
log.dirs=/opt/kafka/kafka-logs
listeners=PLAINTEXT://localhost:9092
bin/kafka-server-start.sh config/server.properties
✅ 看到 Kafka Server started 即成功
bin/kafka-topics.sh \
--create \
--topic test-topic \
--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-topic \
--bootstrap-server localhost:9092
输入:
hello kafka
bin/kafka-console-consumer.sh \
--topic test-topic \
--from-beginning \
--bootstrap-server localhost:9092
✅ 能看到 hello kafka 说明 Kafka 工作正常
netstat -tanp | grep 9092
netstat -tanp | grep 2181
nohup bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeper.log 2>&1 &
nohup bin/kafka-server-start.sh config/server.properties > kafka.log 2>&1 &
安装 Java
↓
下载 Kafka
↓
启动 Zookeeper
↓
启动 Kafka
↓
创建 Topic
↓
生产 / 消费消息
如果你需要:
直接跟我说,我可以一步步给你搭 ✅