下面给你一个**在 Linux 上配置 Kafka(以 Kafka 3.x + Zookeeper 模式为例)**的简明实操指南,适合新手快速搭建。
Kafka 依赖 Java:
java -version
如果没有:
sudo apt update
sudo apt install openjdk-11-jdk -y
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
vim /opt/kafka/config/zookeeper.properties
默认重点:
dataDir=/tmp/zookeeper
clientPort=2181
vim /opt/kafka/config/server.properties
常用关键配置:
broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://你的IP:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181
⚠️ 如果是云服务器,
advertised.listeners必须写外网/内网 IP
cd /opt/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties
新开一个终端:
cd /opt/kafka
bin/kafka-server-start.sh config/server.properties
bin/kafka-topics.sh --create \
--topic test \
--bootstrap-server localhost:9092 \
--partitions 1 \
--replication-factor 1
bin/kafka-console-producer.sh \
--topic test \
--bootstrap-server localhost:9092
bin/kafka-console-consumer.sh \
--topic test \
--from-beginning \
--bootstrap-server localhost:9092
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 &
sudo ufw allow 9092
sudo ufw allow 2181
advertised.listeners 配置错误localhost 但客户端在别的机器如果你用的是 Kafka 3.x+,也可以不用 Zookeeper,我也可以给你 KRaft 配置教程。
如果你告诉我:
我可以直接给你定制版配置。