下面以 Linux(以 CentOS / Ubuntu 为例) 说明 Kafka 的安装与基本启动步骤。Kafka 依赖 Java,我会从环境准备开始。
sudo yum install -y java-1.8.0-openjdk
sudo apt update
sudo apt install -y openjdk-8-jdk
验证:
java -version
mkdir -p /opt/kafka
cd /opt/kafka
以 Kafka 3.6.1 为例(Scala 2.13):
wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz
解压:
tar -zxvf kafka_2.13-3.6.1.tgz
cd kafka_2.13-3.6.1
目录结构说明:
bin/:启动脚本config/:配置文件logs/:日志目录Kafka 依赖 Zookeeper(新版本也可使用 KRaft,下面先讲 Zookeeper 方式)。
bin/zookeeper-server-start.sh config/zookeeper.properties
后台运行(推荐):
nohup bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeper.log 2>&1 &
bin/kafka-server-start.sh config/server.properties
后台运行:
nohup bin/kafka-server-start.sh config/server.properties > kafka.log 2>&1 &
jps
应看到:
QuorumPeerMain # Zookeeper
Kafka
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
bin/kafka-console-consumer.sh \
--topic test-topic \
--from-beginning \
--bootstrap-server localhost:9092
9092 是否被占用netstat -tunlp | grep 9092
编辑:
vim config/server.properties
修改:
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://<服务器IP>:9092
如果你使用的是 Kafka 3.x+,可以不用 Zookeeper:
# 生成 UUID
bin/kafka-storage.sh random-uuid
# 格式化日志目录
bin/kafka-storage.sh format -t <UUID> -c config/kraft/server.properties
# 启动
bin/kafka-server-start.sh config/kraft/server.properties
✅ 安装步骤:
如果你需要:
可以告诉我你的使用场景,我可以给你更完整的方案。