下面给你一份 在 Ubuntu 上安装并配置 Kafka(以 Kafka 3.x + 自带 Zookeeper 为例) 的简明步骤,适合新手直接照着做。
Kafka 依赖 Java(推荐 JDK 8 或 11):
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
Kafka 自带 Zookeeper 配置文件:
/opt/kafka/config/zookeeper.properties
默认端口:2181
编辑:
sudo nano /opt/kafka/config/server.properties
关键配置(单机示例):
broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://localhost:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181
如果是服务器远程访问,把
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
Requires=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
sudo systemctl daemon-reload
sudo systemctl enable kafka
netstat -tunlp | grep 9092
advertised.listenerssudo ufw allow 9092
如果你告诉我:
我可以给你 更精准的配置方案。