下面给你一份在 Ubuntu 上配置 Kafka(单机版)的清晰步骤,适合开发/测试环境。如果你要的是集群版或生产环境,我也可以再补充。
sudo apt update
sudo apt install -y openjdk-11-jdk
验证:
java -version
以 Kafka 3.x 为例(自带 Zookeeper)
cd /opt
sudo wget https://archive.apache.org/dist/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
cd /opt/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties
新终端执行下一步
cd /opt/kafka
bin/kafka-server-start.sh config/server.properties
看到 started (kafka.server.KafkaServer) 说明启动成功。
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
输入任意内容回车。
bin/kafka-console-consumer.sh \
--topic test \
--from-beginning \
--bootstrap-server localhost:9092
配置文件:
/opt/kafka/config/server.properties
常见修改:
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://你的IP:9092
修改后重启 Kafka。
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
bin/kafka-server-start.sh -daemon config/server.properties
✅ 端口被占用
lsof -i:9092
✅ Kafka 起不来
logs/ 目录下日志如果你需要:
告诉我你的使用场景即可。