下面以 Debian 11/12 为例,说明 Kafka 的安装与基本配置(使用官方二进制包,最常用、最稳定)。
Kafka 依赖 JVM(推荐 Java 8 / 11 / 17)
sudo apt update
sudo apt install -y openjdk-17-jdk
验证:
java -version
sudo useradd -m -s /bin/bash kafka
cd /opt
sudo wget https://downloads.apache.org/kafka/3.7.0/kafka_2.13-3.7.0.tgz
sudo tar -xzf kafka_2.13-3.7.0.tgz
sudo mv kafka_2.13-3.7.0 kafka
sudo chown -R kafka:kafka /opt/kafka
cd /opt/kafka
vim config/zookeeper.properties
常用配置:
dataDir=/tmp/zookeeper
clientPort=2181
vim 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
bin/zookeeper-server-start.sh config/zookeeper.properties
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
sudo vim /etc/systemd/system/zookeeper.service
[Unit]
Description=Zookeeper
After=network.target
[Service]
User=kafka
ExecStart=/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties
ExecStop=/opt/kafka/bin/zookeeper-server-stop.sh
[Install]
WantedBy=multi-user.target
sudo vim /etc/systemd/system/kafka.service
[Unit]
Description=Kafka
After=zookeeper.service
[Service]
User=kafka
ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties
ExecStop=/opt/kafka/bin/kafka-server-stop.sh
[Install]
WantedBy=multi-user.target
sudo systemctl daemon-reload
sudo systemctl enable --now zookeeper
sudo systemctl enable --now kafka
如果你用 Kafka 3.3+,可不使用 Zookeeper:
bin/kafka-storage.sh format \
--config config/kraft/server.properties \
--cluster-id abcdefghijklmnopqrstuv
bin/kafka-server-start.sh config/kraft/server.properties
sudo ufw allow 9092
advertised.listenerslog.dirs 到持久目录如果你告诉我:
我可以给你 更精确的配置方案。