下面给你一份**在 Ubuntu 上安装并配置 Kafka(单机版)**的实用流程,适用于 Ubuntu 20.04 / 22.04,Kafka 3.x 版本。
sudo apt update
sudo apt install -y openjdk-11-jdk
验证:
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
编辑:
sudo nano /opt/kafka/config/zookeeper.properties
常用配置:
dataDir=/opt/kafka/zookeeper-data
clientPort=2181
创建目录:
sudo mkdir -p /opt/kafka/zookeeper-data
编辑:
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
创建日志目录:
sudo mkdir -p /opt/kafka/kafka-logs
✅ 如果是远程访问,把 localhost 改成服务器 IP。
/opt/kafka/bin/zookeeper-server-start.sh -daemon /opt/kafka/config/zookeeper.properties
/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties
查看进程:
jps
应看到:
/opt/kafka/bin/kafka-topics.sh \
--create \
--topic test \
--bootstrap-server localhost:9092 \
--partitions 1 \
--replication-factor 1
/opt/kafka/bin/kafka-console-producer.sh \
--topic test \
--bootstrap-server localhost:9092
输入:
hello kafka
/opt/kafka/bin/kafka-console-consumer.sh \
--topic test \
--from-beginning \
--bootstrap-server localhost:9092
sudo nano /etc/systemd/system/kafka.service
[Unit]
Description=Apache Kafka
After=zookeeper.service
[Service]
Type=simple
ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
ExecStop=/opt/kafka/bin/kafka-server-stop.sh
Restart=on-abnormal
[Install]
WantedBy=multi-user.target
同理可建 zookeeper.service。
✅ 端口占用
sudo netstat -tunlp | grep 9092
✅ Kafka 3.x 可不用 Zookeeper(KRaft) 如果你要用 无 Zookeeper 模式,我也可以单独给你 KRaft 配置。
如果你告诉我:
我可以直接给你一份精简可用配置。